Module stream_consumer

High-level consumers with a Stream interface.

Structs

• MessageStream
  A stream of messages from a StreamConsumer.
• StreamConsumer
  A high-level consumer with a Stream interface.
• StreamPartitionQueue
  A message queue for a single partition of a StreamConsumer.