Module local 

Sessions between two peers in one process.

r[impl jetstream.session.local] Two peers in one process hold a session without a transport. It reports many lanes, no datagrams and no identity, and its lanes give the same ordering guarantees a transport-backed lane does.

r[impl jetstream.session.local.no-serialisation] Frames move between the two ends as values. Nothing is encoded to bytes to obtain ordering: ordering is what the lane provides, and in-process it is provided by the lane itself.

Structs

LocalClientLane

The caller’s end of an in-process lane.

LocalServiceLane

The callee’s end of an in-process lane.

LocalSession

One end of an in-process session.

LocalSessionPair

The two ends of an in-process session.

OrderedSender

Writes frames to one lane in the order their tickets were taken.

Constants

DEFAULT_LANE_CAPACITY

Frames a lane will hold before the writer is told to wait.