Struct InterlaceMachine 

pub struct InterlaceMachine { /* private fields */ }

The sole semantic owner of either a same-runtime pair or one connected carrier.

Implementations

impl InterlaceMachine

pub fn new_direct(config: DirectConfig) -> Result<Self, CoreError>

pub fn new_connected( role: CarrierRole, config: ConnectedConfig, ) -> Result<Self, CoreError>

pub fn protocol_phase_token( &self, side: InterlaceSide, ) -> Option<ProtocolPhaseToken>

pub fn active_store_call(&self, side: InterlaceSide) -> Option<&StoreCall>

pub fn active_store_call_mut( &mut self, side: InterlaceSide, ) -> Option<&mut StoreCall>

pub fn replace_direct_policy( &mut self, operands: [InterlaceModule; 2], ) -> Result<(), CoreError>

pub fn replace_connected_policy( &mut self, operand: InterlaceModule, ) -> Result<(), CoreError>

pub fn submit_store_call(&mut self, id: u64) -> Result<(), MachineError>

pub fn try_store_position_advanced( &mut self, boundary: &FixedPointWakeBoundary, position: StorePosition, ) -> StorePositionAdvance

pub fn timeout(&mut self, side: InterlaceSide) -> Result<(), CoreError>

pub fn can_read_peer_input(&self) -> Result<bool, CoreError>

pub fn peer_record_ingress(&self) -> Result<RecordIngress, CoreError>

pub fn peer_input_disposition( &self, input: &PeerInput, ) -> Result<PeerInputDisposition, CoreError>

pub fn push_peer_input( &mut self, input: impl Into<PeerInput>, ) -> Result<(), MachineError>

pub fn accept_peer_output(&mut self) -> Result<Vec<IltpItem>, MachineError>

Accept the retained connected output. A terminal transition this causes returns the same error the next poll reports as Failed. Accept the polled peer output, handing its items to the writer.

pub fn adopt_operand_cache( &mut self, cache: OperandCache, ) -> Result<(), MachineError>

Answer MachinePoll::SelectOperand on a port-selecting carrier: this logical session’s operand, or None to refuse the port. Share cache with every logical session, while the first operand selection is unanswered (ConnectedCarrier::adopt_operand_cache).

pub fn select_operand( &mut self, selection: Option<SessionOperand>, ) -> Result<(), MachineError>

pub fn peer_port(&self) -> Option<&PortText>

The port of the latest peer preface; a direct pair has none.

pub fn peer_by(&self) -> Option<&ByValue>

The By the live peer proved in the latest logical session; a direct pair has none.

pub fn outgoing_encoding(&self) -> Option<StreamEncoding>

The encoding of the local-to-peer direction the latest preface pair selects; a direct pair has none.

pub fn incoming_encoding(&self) -> Option<StreamEncoding>

The encoding of the peer-to-local direction the latest preface pair selects; a direct pair has none.

pub fn peer_diagnostics(&self) -> PeerDiagnostics

The connected route’s diagnostics for a bounded outcome.

pub fn peer_eof(&mut self) -> Result<(), MachineError>

pub fn cancel(&mut self)

pub fn poll(&mut self) -> MachinePoll<'_>

Trait Implementations

impl Debug for InterlaceMachine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.