Struct InternalSessionRef 

pub struct InternalSessionRef<Outbound> { /* private fields */ }

Implementations

impl<Outbound: OutboundMessage> InternalSessionRef<Outbound>

pub fn new( config: SessionConfig, application: impl Application<Outbound = Outbound>, store: impl MessageStore + 'static, ) -> Result<Self, SessionCreationError>

pub async fn register_writer( &self, writer: WriterRef, ) -> Result<(), SessionGone>

pub async fn new_fix_message_received( &self, msg: RawFixMessage, ) -> Result<(), SessionGone>

pub async fn disconnect(&self, reason: String) -> Result<(), SessionGone>

pub async fn should_reconnect(&self) -> Result<bool, SessionGone>

pub async fn await_in_schedule(&self) -> Result<ScheduleResponse, SessionGone>

Trait Implementations

impl<Outbound: Clone> Clone for InternalSessionRef<Outbound>

fn clone(&self) -> InternalSessionRef<Outbound>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M> From<InternalSessionRef<M>> for SessionHandle<M>

fn from(session_ref: InternalSessionRef<M>) -> Self

Converts to this type from the input type.