Module step 

Step primitives. Step primitives.

Enums

TransformOutcome

Outcome of a stage transform.

Functions

publish_slot_with_policy_or_copy

Publish an owned slot with on_full backpressure semantics.

publish_with_policy

Publish a message to a lane, applying on_full backpressure semantics with an explicit wait strategy.

recv_map_ok_publish_with_step

Receive → (MapOk) transform → publish-with (slot write).

recv_select_publish_batch

Receive from one of N RX lanes (round-robin) → publish, up to batch messages.

recv_select_publish_step

Receive from one of N RX lanes (round-robin) → publish.

recv_slot_filter_forward_publish_slot_step

Receive-slot → filter → (forward via slot if true).

recv_slot_forward_publish_slot_step

Receive-slot → forward → publish-slot.

recv_slot_inspect_forward_publish_slot_step

Receive-slot → inspect → (forward via slot).

recv_slot_transform_forward_publish_slot_step

Receive-slot → transform → (forward via slot on ForwardInput).

recv_transform_publish_batch

Receive → transform → publish, up to batch messages.

recv_transform_publish_step

Receive → transform → publish primitive.

recv_with_forward_publish_with_step

Receive-with (borrowed) → forward → publish-with (slot write).

recv_with_map_ok_publish_with_step

Receive-with (borrowed) → (MapOk) transform → publish-with (slot write).

recv_with_map_publish_with_result_step

Receive-with (borrowed) → (Map) transform → publish-with (slot write), fallible.

recv_with_transform_publish_batch

Receive-with (borrowed) → transform → publish, up to batch messages.

recv_with_transform_publish_step

Receive-with (borrowed) → transform → publish primitive.