Skip to main content

Module stream_ref

Module stream_ref 

Source
Expand description

StreamRefs over QUIC.

datum-core owns the protobuf protocol and state machine. This module is the carrier: it length-prefixes protobuf frames and pumps them over one reliable, ordered QUIC bidirectional byte stream.

Structs§

StreamRefQuicHandle
Completion handle for a StreamRefs-over-QUIC 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_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.
sink_ref_over_quic
Creates a local Sink that sends its incoming elements over QUIC to a remote SinkRef receiver.
source_ref_over_quic
Creates a local source fed by a remote QUIC StreamRef producer.