StreamChannel<T> class abstract

An abstract class representing a two-way communication channel.

Users should consider the stream emitting a "done" event to be the canonical indicator that the channel has closed. If they wish to close the channel, they should close the sink; canceling the stream subscription is not sufficient.

Implementers

Constructors

StreamChannel(Stream<T> stream, StreamSink<T> sink)
Creates a new StreamChannel that communicates over stream and sink.
factory
StreamChannel.withCloseGuarantee(Stream<T> stream, StreamSink<T> sink)
Creates a new StreamChannel that communicates over stream and sink.
factory

Properties

hashCode → int
The hash code for this object.
no setterinherited
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
sink → StreamSink<T>
The sink for sending values to the other endpoint.
no setter
stream → Stream<T>
The single-subscription stream that emits values from the other endpoint.
no setter

Methods

cast<S>() → StreamChannel<S>
Returns a copy of this with the generic type coerced to S.
changeSink(StreamSink<T> change(StreamSink<T>)) → StreamChannel<T>
Returns a copy of this with sink replaced by change's return value.
changeStream(Stream<T> change(Stream<T>)) → StreamChannel<T>
Returns a copy of this with stream replaced by change's return value.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
pipe(StreamChannel<T> other) → void
Connects this to other, so that any values emitted by either are sent directly to the other.
toString() → String
A string representation of this object.
inherited
transform<S>(StreamChannelTransformer<S, T> transformer) → StreamChannel<S>
Transforms this using transformer.
transformSink(StreamSinkTransformer<T, T> transformer) → StreamChannel<T>
Transforms only the sink component of this using transformer.
transformStream(StreamTransformer<T, T> transformer) → StreamChannel<T>
Transforms only the stream component of this using transformer.

Operators

operator ==(Object other) → bool
The equality operator.
inherited