Module streaming

Module streaming 

Source
Expand description

Streaming protocol abstractions for pub/sub and messaging patterns

This module provides traits and types for protocols that support streaming, pub/sub, and asynchronous messaging patterns like MQTT, Kafka, and RabbitMQ.

Structs§

MessageBuilder
Helper for creating protocol messages
ProtocolMessage
A message in a streaming protocol
StreamingMetadata
Metadata about a streaming connection
StreamingProtocolRegistry
A registry for managing multiple streaming protocol handlers

Traits§

StreamingProtocol
Trait for protocols that support streaming and pub/sub patterns

Type Aliases§

MessageStream
A stream of protocol messages