Comments (4)
Thanks for the feedback Rich,
the use case would be like an FromFuturePublisher, so it only can send up to 1 element, right?
We'll try to figure something out, may be easy enough to integrate your request.
from reactive-streams-jvm.
Yes, my use case is single-element publishers and consumers made by wrapping Scala's futures and promises. I can also imagine zero-element versions of publishers and consumers (Publisher.empty, Consumer.empty) and versions of publishers and consumers that can only handle finite lengths (Publisher.fromArray, Consumer.toArray).
from reactive-streams-jvm.
So my current suggestion would be (as seen in PR #91):
@Override
public long maxElementsFromPublisher() { return 1; }
Which skips all tests which require more than 1 element to run (so currently, most of them: Total tests run: 18, Failures: 0, Skips: 13
(publisher specs)). The skip message includes this as the reason. Opinions about this way of exposing publisher capabilities?
from reactive-streams-jvm.
Looks like it was solved to me. Closing.
from reactive-streams-jvm.
Related Issues (20)
- Error handling is just wrong? HOT 8
- Is there a way to block/wait? HOT 1
- org.reactivestreams.Subscription add cancelOnError(Throwable) method
- Upgrade testng in reactive-streams-tck HOT 1
- Release a new version? HOT 14
- Consider adding a full Java module descriptor HOT 1
- Subscription.cancel MUST BE thread-safe HOT 4
- issue with the License HOT 4
- Example code in java.util.concurrent.
- 1.0.4 javadoc on reactive-streams.org missing HOT 1
- Bundle-SymbolicName changed from 1.0.3 to 1.0.4 HOT 2
- Subscriber payload or contextualize request HOT 4
- Bounded publisher onComplete signal timing (related to rule 1.5) HOT 4
- F
- Please include license text into the release jars, and add Bundle-License to MANIFEST.MF
- DEFAULT_POLL_TIMEOUT_MILLIS is not read by the no-args TestEnvironment xtor HOT 1
- Empty TCKVerificationSupport.java in the repo HOT 3
- RangePublisher - Possible example improvement? HOT 5
- add MonoPublisher and Closeable interface , developer duplication define Closeable interface HOT 2
- Can onNext may be signalled before onSubscribe returns? HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from reactive-streams-jvm.