Module stream_ref 

Remote StreamRefs carriers.

datum-core owns the protobuf protocol and state machine. This module is the carrier layer: it length-prefixes protobuf frames and pumps them over reliable, ordered bidirectional byte streams such as QUIC or plaintext TCP.

Structs

StreamRefProtocolDiagnostics

Shared collector for StreamRefs protocol message-count diagnostics.

StreamRefProtocolMessageCounts

Counts selected StreamRefs protocol messages successfully written by a carrier endpoint.

StreamRefQuicHandle

Completion handle for a StreamRefs-over-QUIC carrier.

StreamRefTcpBinding

Local TCP listener binding used by StreamRefs-over-TCP producer endpoints.

StreamRefTcpHandle

Completion handle for a StreamRefs-over-TCP carrier.

Functions

serve_sink_ref_over_quic

Serves a local SinkRef receiver over an accepted or opened QUIC bidi stream, returning a Source of inbound elements.

serve_sink_ref_over_tcp

Serves a remote SinkRef receiver over plaintext TCP.

serve_sink_ref_over_tcp_stream

Serves a remote SinkRef receiver over an already-connected Tokio TCP stream.

serve_sink_ref_over_tcp_stream_with_diagnostics

serve_sink_ref_over_tcp_with_diagnostics

serve_source_over_quic

Serves a local Source over an accepted or opened QUIC bidi stream.

serve_source_ref_over_quic

Serves a local SourceRef over an accepted or opened QUIC bidi stream.

serve_source_ref_over_tcp

Serves a local SourceRef over a one-shot plaintext TCP listener.

serve_source_ref_over_tcp_stream

Serves a local SourceRef over an already-connected Tokio TCP stream.

serve_source_ref_over_tcp_stream_with_diagnostics

serve_source_ref_over_tcp_with_diagnostics

sink_ref_over_quic

Creates a local Sink that sends its incoming elements over QUIC to a remote SinkRef receiver.

sink_ref_over_tcp

Creates a local Sink whose incoming elements are sent over a one-shot plaintext TCP listener to a remote SinkRef receiver.

sink_ref_over_tcp_stream

Creates a local Sink whose incoming elements are sent over an already-connected Tokio TCP stream to a remote SinkRef receiver.

sink_ref_over_tcp_stream_with_diagnostics

sink_ref_over_tcp_with_diagnostics

source_ref_over_quic

Creates a local source fed by a remote QUIC StreamRef producer.

source_ref_over_tcp

Creates a local source fed by a remote plaintext TCP StreamRef producer.

source_ref_over_tcp_stream

Creates a local source fed by a remote producer over an already-connected Tokio TCP stream.

source_ref_over_tcp_stream_with_diagnostics

source_ref_over_tcp_with_diagnostics