Reader

scalus.testing.stream.StreamProviderConformance.Reader
final protected class Reader[A](val source: ScalusAsyncSource[A])

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 Object
trait Matchable
class Any

Members list

Value members

Concrete methods

def cancel(): Unit
def drain(): List[A]

Everything already delivered.

Everything already delivered.

Attributes

def isEnded: Boolean
def next(): A

Wait for the next event.

Wait for the next event.

Attributes

def peek(): Option[A]

The next event if one has already arrived; does not wait for one that has not.

The next event if one has already arrived; does not wait for one that has not.

Attributes

Concrete fields