Module stream_ref_proto 

Protobuf StreamRefs protocol and transport-agnostic endpoint drivers.

This module mirrors Akka’s StreamRefs protocol without embedding an actor transport. A carrier feeds inbound protobuf frames into one endpoint and drains outbound frames from the same endpoint. datum-net uses this seam to carry StreamRefs over a reliable, ordered QUIC bidirectional stream.

Structs

StreamRefFrame

One protobuf frame tagged with a connection-scoped stream-ref id.

StreamRefId

Stream-ref identifier scoped to one transport connection.

StreamRefPayloadBatch

A contiguous batch of already-encoded SequencedOnNext payloads.

StreamRefPayloadBytes

Protobuf payload wrapper matching Akka’s Payload, without Akka serializer ids or manifests.

StreamRefProtoConsumer

Consumer-side endpoint that exposes inbound remote elements as a local Source.

StreamRefProtoProducer

Producer-side endpoint for a local SourceRef or Source.

Enums

StreamRefMessage

Transport-agnostic StreamRefs protocol messages.

StreamRefOutbound

An outbound protocol item. Control remains a protobuf frame; steady data can move as one compact batch without first inflating one frame per element.

Traits

StreamRefPayload

Element payload codec used by the protobuf StreamRefs transport seam.

StreamRefProtoEndpoint

Common interface for external carriers that pump protobuf frames.