Module streaming 

Streaming support utilities for gRPC

This module provides utilities for handling streaming RPCs:

• Client streaming (receiving stream of messages)
• Server streaming (sending stream of messages)
• Bidirectional streaming (both directions)

Structs

StreamingRequest

Request for client streaming RPC

StreamingResponse

Response for server streaming RPC

Functions

empty_message_stream

Helper to create an empty message stream

error_stream

Helper to create an error stream

from_tonic_stream

Helper to convert a Tonic ReceiverStream to our MessageStream

message_stream_from_vec

Helper to create a message stream from a vector of bytes

single_message_stream

Helper to create a single-message stream

Type Aliases

MessageStream

Type alias for a stream of protobuf message bytes