pub struct AppServerClient { /* private fields */ }Implementations§
Source§impl AppServerClient
impl AppServerClient
pub fn new_for_processor( processor: MessageProcessor, outgoing: Receiver<OutgoingEnvelope>, connection_id: ConnectionId, ) -> Self
pub async fn initialize( &mut self, info: AppClientInfo, ) -> Result<InitializeResponse, AppServerClientError>
pub async fn start_thread( &mut self, params: ThreadStartParams, ) -> Result<ThreadStartResponse, AppServerClientError>
pub async fn resume_thread( &mut self, params: ThreadResumeParams, ) -> Result<ThreadResumeResponse, AppServerClientError>
pub async fn read_thread( &mut self, params: ThreadReadParams, ) -> Result<ThreadReadResponse, AppServerClientError>
pub async fn list_threads( &mut self, params: ThreadListParams, ) -> Result<ThreadListResponse, AppServerClientError>
pub async fn archive_thread( &mut self, params: ThreadArchiveParams, ) -> Result<ThreadArchiveResponse, AppServerClientError>
pub async fn unsubscribe_thread( &mut self, params: ThreadUnsubscribeParams, ) -> Result<ThreadUnsubscribeResponse, AppServerClientError>
pub async fn start_turn( &mut self, params: TurnStartParams, ) -> Result<TurnStartResponse, AppServerClientError>
pub async fn resume_turn( &mut self, params: TurnResumeParams, ) -> Result<TurnResumeResponse, AppServerClientError>
pub async fn interrupt_turn( &mut self, params: TurnInterruptParams, ) -> Result<TurnInterruptResponse, AppServerClientError>
pub async fn steer_turn( &mut self, params: TurnSteerParams, ) -> Result<TurnSteerResponse, AppServerClientError>
pub async fn follow_up_turn( &mut self, params: TurnFollowUpParams, ) -> Result<TurnFollowUpResponse, AppServerClientError>
pub async fn resolve_approval( &mut self, params: ApprovalResolveParams, ) -> Result<(), AppServerClientError>
pub async fn resolve_approval_request( &mut self, params: ApprovalResolveParams, ) -> Result<(), AppServerClientError>
pub async fn send_response( &mut self, request_id: RequestId, result: Value, ) -> Result<(), AppServerClientError>
pub async fn list_models( &mut self, params: ModelListParams, ) -> Result<ModelListResponse, AppServerClientError>
pub async fn export_schema( &mut self, ) -> Result<SchemaExportResponse, AppServerClientError>
pub async fn next_message(&mut self) -> Option<JsonRpcMessage>
pub async fn try_next_message( &mut self, ) -> Result<JsonRpcMessage, AppServerClientError>
pub async fn close(&mut self) -> bool
Auto Trait Implementations§
impl !RefUnwindSafe for AppServerClient
impl !UnwindSafe for AppServerClient
impl Freeze for AppServerClient
impl Send for AppServerClient
impl Sync for AppServerClient
impl Unpin for AppServerClient
impl UnsafeUnpin for AppServerClient
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.