Reader
scalus.testing.stream.StreamProviderConformance.Reader
A reader that never drops an event.
pull is a commitment, not a poll: on an empty source it installs a waiter that the next offered event completes. Calling pull and discarding the future would therefore route the next event into a promise nobody holds — invisible against a provider that delivers synchronously, and silent data loss against every remote one this suite exists to certify. So the outstanding future is kept and re-inspected instead.
Attributes
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
Members list
In this article