pub struct MessageProcessor { /* private fields */ }Implementations§
Source§impl MessageProcessor
impl MessageProcessor
pub fn new(outgoing_capacity: usize) -> (Self, Receiver<OutgoingEnvelope>)
pub fn new_with_host( outgoing_capacity: usize, host: Arc<dyn AppServerHost>, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn with_runtime( outgoing_capacity: usize, runner: Runner, agent: Agent, store: SqliteThreadStore, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn with_runtime_and_approval_timeout( outgoing_capacity: usize, runner: Runner, agent: Agent, store: SqliteThreadStore, approval_request_timeout: Duration, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn with_host( outgoing_capacity: usize, runner: Runner, host: Arc<dyn AppServerHost>, store: SqliteThreadStore, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn with_host_and_approval_timeout( outgoing_capacity: usize, runner: Runner, host: Arc<dyn AppServerHost>, store: SqliteThreadStore, approval_request_timeout: Duration, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn with_host_and_durable_resume_provider( outgoing_capacity: usize, runner: Runner, host: Arc<dyn AppServerHost>, store: SqliteThreadStore, provider: Arc<dyn DurableTurnResumeProvider>, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn with_runtime_and_durable_resume_provider( outgoing_capacity: usize, runner: Runner, agent: Agent, store: SqliteThreadStore, provider: Arc<dyn DurableTurnResumeProvider>, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn new_for_tests( outgoing_capacity: usize, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn new_for_tests_with_runtime( outgoing_capacity: usize, runner: Runner, agent: Agent, store: SqliteThreadStore, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn new_for_tests_with_runtime_and_approval_timeout( outgoing_capacity: usize, runner: Runner, agent: Agent, store: SqliteThreadStore, approval_request_timeout: Duration, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn new_for_tests_with_runtime_and_durable_resume_provider( outgoing_capacity: usize, runner: Runner, agent: Agent, store: SqliteThreadStore, provider: Arc<dyn DurableTurnResumeProvider>, ) -> (Self, Receiver<OutgoingEnvelope>)
pub fn outgoing(&self) -> &OutgoingMessageSender
pub fn connection_state( &self, connection_id: ConnectionId, ) -> Option<&ConnectionSessionState>
pub fn connection_ids(&self) -> Vec<ConnectionId>
pub async fn disconnect_connection(&mut self, connection_id: ConnectionId)
pub async fn process_message( &mut self, connection_id: ConnectionId, message: JsonRpcMessage, )
Auto Trait Implementations§
impl !RefUnwindSafe for MessageProcessor
impl !UnwindSafe for MessageProcessor
impl Freeze for MessageProcessor
impl Send for MessageProcessor
impl Sync for MessageProcessor
impl Unpin for MessageProcessor
impl UnsafeUnpin for MessageProcessor
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreCreates a shared type from an unshared type.