Module stream

Structs§

NoopForward: Used by StreamPack to implement the StreamPack::forward_channels method for an empty tuple.
Require: Used by ServiceDiscovery to indicate that a certain pack of streams is required.
StreamAvailable: StreamAvailable is a marker component that indicates what streams are offered by a service.
StreamBuffer
StreamForward: Used to forward the data from a stream receiver into a different StreamChannel.
StreamOf: A simple newtype wrapper that turns any suitable data structure ('static + Send + Sync) into a stream.
StreamPackForward: Used by StreamPack to implement the StreamPack::forward_channels method for a non-empty tuple.
StreamRequest
StreamTargetMap: The actual entity target of the stream is held in this component which does not have any generic parameters. This means it is possible to lookup the targets of the streams coming out of the node without knowing the concrete type of the streams. This is crucial for being able to redirect the stream targets.
StreamTargetStorage: StreamTargetStorage keeps track of the target for each stream for a source.

Stream
StreamFilter: Used by ServiceDiscovery to filter services based on what streams they provide. If a stream is required, you should wrap the stream type in Require. If a stream is optional, then wrap it in Option.
StreamPack: The StreamPack trait defines the interface for a pack of streams. Each Provider can provide zero, one, or more streams of data that may be sent out while it’s running. The StreamPack allows those streams to be packed together as one generic argument.