Struct kayrx::jrpc::raw::RawServer

pub struct RawServer<R, I> { /* fields omitted */ }

Wraps around a "raw server" and adds capabilities.

See the module-level documentation for more information.

Methods

impl<R, I> RawServer<R, I> where
    R: TransportServer<RequestId = I>,
    I: Clone + PartialEq + Eq + Hash + Send + Sync, 

pub fn new(inner: R) -> RawServer<R, I>

Starts a RawServer using the given raw server internally.

impl<R, I> RawServer<R, I> where
    R: TransportServer<RequestId = I>,
    I: Clone + PartialEq + Eq + Hash + Send + Sync, 

pub async fn next_event<'a>(&'a mut self) -> RawServerEvent<'a, R, I>

Returns a Future resolving to the next event that this server generates.

pub fn request_by_id<'a>(
    &'a mut self,
    id: &RawServerRequestId
) -> Option<RawServerRequest<'a, R, I>>

Returns a request previously returned by next_event by its id.

Note that previous notifications don't have an ID and can't be accessed with this method.

Returns None if the request ID is invalid or if the request has already been answered in the past.

pub fn subscription_by_id(
    &mut self,
    id: RawServerSubscriptionId
) -> Option<ServerSubscription<R, I>>

Returns a subscription previously returned by into_subscription.

Trait Implementations

impl<R> From<R> for RawServer<R, R::RequestId> where
    R: TransportServer, 

fn from(inner: R) -> RawServer<R, R::RequestId>

Performs the conversion.

impl<R, I> From<RawServer<R, I>> for Server where
    R: TransportServer<RequestId = I> + Send + Sync + 'static,
    I: Clone + PartialEq + Eq + Hash + Send + Sync + 'static, 

Initializes a new server based upon this raw server.

fn from(server: RawServer<R, I>) -> Server

Performs the conversion.