Module crossbus::stream

Stream Execution Routine and Events

Structs

• Streaming
  streaming a batch of items and send them to Stream::action

Enums

• StreamState
  Stream state
• StreamingState
  Indicator to direct the Streaming at runtime,

Traits

• Stream
  An abstraction for Actor’s stream routine