Crate rstreams

Modules

• actor
  Execute streams in asynchronous Tokio tasks.
• error
• join
  Merge streams into one based on timeframes.
• store
  Key-Value store
• table
  Changelog stream
• window
  Divide stream into time based segments.

Structs

• ParsedMessage

Traits

• Dated

Functions

• erase_stream_type
• from_bytes
• to_bytes
• within_window