Struct RoleClient 

pub struct RoleClient;

Trait Implementations

impl Clone for RoleClient

fn clone(&self) -> RoleClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoleClient

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

Formats the value using the given formatter.

impl Default for RoleClient

fn default() -> RoleClient

Returns the “default value” for a type.

impl PartialEq for RoleClient

fn eq(&self, other: &RoleClient) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<H> Service<RoleClient> for H

where H: ClientHandler,

async fn handle_request( &self, request: <RoleClient as ServiceRole>::PeerReq, context: RequestContext<RoleClient>, ) -> Result<<RoleClient as ServiceRole>::Resp, ErrorData>

async fn handle_notification( &self, notification: <RoleClient as ServiceRole>::PeerNot, context: NotificationContext<RoleClient>, ) -> Result<(), ErrorData>

fn get_info(&self) -> <RoleClient as ServiceRole>::Info

impl<S> ServiceExt<RoleClient> for S

where S: Service<RoleClient>,

fn serve_with_ct<T, E, A>( self, transport: T, ct: CancellationToken, ) -> impl Future<Output = Result<RunningService<RoleClient, S>, ClientInitializeError>> + Send

where T: IntoTransport<RoleClient, E, A>, E: Error + Send + Sync + 'static,

fn into_dyn(self) -> Box<dyn DynService<R>>

Convert this service to a dynamic boxed service

fn serve<T, E, A>( self, transport: T, ) -> impl Future<Output = Result<RunningService<R, Self>, <R as ServiceRole>::InitializeError>> + Send

where T: IntoTransport<R, E, A>, E: Error + Send + Sync + 'static, Self: Sized,

impl ServiceRole for RoleClient

const IS_CLIENT: bool = true

type Req = ClientRequest

type Resp = ClientResult

type Not = ClientNotification

type PeerReq = ServerRequest

type PeerResp = ServerResult

type PeerNot = ServerNotification

type Info = InitializeRequestParam

type PeerInfo = InitializeResult

type InitializeError = ClientInitializeError

impl<C> Transport<RoleClient> for SseClientTransport<C>

where C: SseClient,

type Error = SseTransportError<<C as SseClient>::Error>

async fn receive( &mut self, ) -> Option<JsonRpcMessage<ServerRequest, ServerResult, ServerNotification>>

Receive a message from the transport, this operation is sequential.

fn send( &mut self, item: JsonRpcMessage<<RoleClient as ServiceRole>::Req, <RoleClient as ServiceRole>::Resp, <RoleClient as ServiceRole>::Not>, ) -> impl Future<Output = Result<(), <SseClientTransport<C> as Transport<RoleClient>>::Error>> + Send + 'static

Send a message to the transport

async fn close( &mut self, ) -> Result<(), <SseClientTransport<C> as Transport<RoleClient>>::Error>

Close the transport

fn name() -> Cow<'static, str>

impl Transport<RoleClient> for TokioChildProcess

type Error = Error

fn send( &mut self, item: JsonRpcMessage<<RoleClient as ServiceRole>::Req, <RoleClient as ServiceRole>::Resp, <RoleClient as ServiceRole>::Not>, ) -> impl Future<Output = Result<(), <TokioChildProcess as Transport<RoleClient>>::Error>> + Send + 'static

Send a message to the transport

fn receive( &mut self, ) -> impl Future<Output = Option<JsonRpcMessage<<RoleClient as ServiceRole>::PeerReq, <RoleClient as ServiceRole>::PeerResp, <RoleClient as ServiceRole>::PeerNot>>> + Send

Receive a message from the transport, this operation is sequential.

fn close( &mut self, ) -> impl Future<Output = Result<(), <TokioChildProcess as Transport<RoleClient>>::Error>> + Send

Close the transport

fn name() -> Cow<'static, str>

impl Copy for RoleClient

impl Eq for RoleClient

impl StructuralPartialEq for RoleClient