Struct ServerEnd 

pub struct ServerEnd<P, T = <P as HasTransport>::Transport> { /* private fields */ }

The server end of a protocol.

Implementations

impl<P, T> ServerEnd<P, T>

pub fn as_ref(&self) -> ServerEnd<P, &T>

Converts from &ServerEnd<P, T> to ServerEnd<P, &T>.

pub fn from_untyped(transport: T) -> ServerEnd<P, T>

Returns a new endpoint over the given transport.

pub fn into_untyped(self) -> T

Returns the underlying transport.

pub fn executor(&self) -> <T as HasExecutor>::Executor

where T: HasExecutor,

Returns the executor for the underlying transport.

impl<P, T> ServerEnd<P, T>

where T: Transport,

pub fn spawn_full_on_with<H, E>( self, create_handler: impl FnOnce(Server<P, T>) -> H, executor: &E, ) -> (<E as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>, Server<P, T>)

where P: DispatchServerMessage<H, T>, T: 'static, H: Send + 'static, E: Executor,

Spawns a dispatcher for the given server end with a handler computed from a closure on an executor.

Returns the join handle for the spawned task and the server.

pub fn spawn_full_on<H, E>( self, handler: H, executor: &E, ) -> (<E as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>, Server<P, T>)

where P: DispatchServerMessage<H, T>, T: 'static, H: Send + 'static, E: Executor,

Spawns a dispatcher for the given server end with a handler on an executor.

Returns the join handle for the spawned task and the server.

pub fn spawn_on_with<H, E>( self, create_handler: impl FnOnce(Server<P, T>) -> H, executor: &E, ) -> <E as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>

where P: DispatchServerMessage<H, T>, T: 'static, H: Send + 'static, E: Executor,

Spawns a dispatcher for the given server end with a handler computed from a closure on an executor.

Returns the join handle for the spawned task.

pub fn spawn_on<H, E>( self, handler: H, executor: &E, ) -> <E as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>

where P: DispatchServerMessage<H, T>, T: 'static, H: Send + 'static, E: Executor,

Spawns a dispatcher for the given server end with a handler on an executor.

Returns the join handle for the spawned task.

pub fn spawn_full_with<H>( self, create_handler: impl FnOnce(Server<P, T>) -> H, ) -> (<<T as HasExecutor>::Executor as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>, Server<P, T>)

where P: DispatchServerMessage<H, T>, T: HasExecutor + 'static, H: Send + 'static,

Spawns a dispatcher for the given server end with a handler computed from a closure on the default executor for the transport.

Returns the join handle for the spawned task and the server.

pub fn spawn_full<H>( self, handler: H, ) -> (<<T as HasExecutor>::Executor as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>, Server<P, T>)

where P: DispatchServerMessage<H, T>, T: HasExecutor + 'static, H: Send + 'static,

Spawns a dispatcher for the given server end with a handler on the default executor for the transport.

Returns the join handle for the spawned task and the server.

pub fn spawn_with<H>( self, create_handler: impl FnOnce(Server<P, T>) -> H, ) -> <<T as HasExecutor>::Executor as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>

where P: DispatchServerMessage<H, T>, T: HasExecutor + 'static, H: Send + 'static,

Spawns a dispatcher for the given server end with a handler computed from a closure on the default executor for the transport.

Returns the join handle for the spawned task.

pub fn spawn<H>( self, handler: H, ) -> <<T as HasExecutor>::Executor as Executor>::Task<Result<H, ProtocolError<<T as Transport>::Error>>>

where P: DispatchServerMessage<H, T>, T: HasExecutor + 'static, H: Send + 'static,

Spawns a dispatcher for the given server end with a handler on the default executor for the transport.

Returns the join handle for the spawned task.

Trait Implementations

impl<P1, P2, T> CompatFrom<ServerEnd<P1>> for ServerEnd<P2, T>

where T: CompatFrom<Channel>, P2: CompatFrom<P1>,

fn compat_from(value: ServerEnd<P1>) -> ServerEnd<P2, T>

Converts value into a value of this type.

impl<P1, P2, T> CompatFrom<ServerEnd<P1, T>> for ServerEnd<P2>

where Channel: CompatFrom<T>, P2: CompatFrom<P1>,

fn compat_from(value: ServerEnd<P1, T>) -> ServerEnd<P2>

Converts value into a value of this type.

impl<P, T> Debug for ServerEnd<P, T>

where P: Debug, T: Debug,

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

Formats the value using the given formatter.

impl<D, P, T> Decode<D> for ServerEnd<P, T>

where P: 'static, T: Decode<D, Constraint = ()> + Constrained, D: ?Sized,

fn decode( slot: Slot<'_, ServerEnd<P, T>>, decoder: &mut D, constraint: <ServerEnd<P, T> as Constrained>::Constraint, ) -> Result<(), DecodeError>

Decodes a value into a slot using a decoder.

impl<'a, W, E, P, T> Encode<ServerEnd<P, W>, E> for &'a ServerEnd<P, T>

where P: 'static, &'a T: Encode<W, E>, W: Constrained<Constraint = ()> + Wire, E: ?Sized,

fn encode( self, encoder: &mut E, out: &mut MaybeUninit<ServerEnd<P, W>>, constraint: (), ) -> Result<(), EncodeError>

Encodes this value into an encoder and output.

const COPY_OPTIMIZATION: CopyOptimization<Self, W> = _

Whether the conversion from Self to W is equivalent to copying the raw bytes of Self.

impl<W, E, P, T> Encode<ServerEnd<P, W>, E> for ServerEnd<P, T>

where P: 'static, T: Encode<W, E>, W: Constrained<Constraint = ()> + Wire, E: ?Sized,

fn encode( self, encoder: &mut E, out: &mut MaybeUninit<ServerEnd<P, W>>, constraint: (), ) -> Result<(), EncodeError>

Encodes this value into an encoder and output.

const COPY_OPTIMIZATION: CopyOptimization<Self, W> = _

Whether the conversion from Self to W is equivalent to copying the raw bytes of Self.

impl<'a, W, E, P, T> EncodeOption<ServerEnd<P, W>, E> for &'a ServerEnd<P, T>

where P: 'static, &'a T: EncodeOption<W, E>, W: Constrained<Constraint = ()>, E: ?Sized,

fn encode_option( this: Option<&'a ServerEnd<P, T>>, encoder: &mut E, out: &mut MaybeUninit<ServerEnd<P, W>>, constraint: (), ) -> Result<(), EncodeError>

Encodes this optional value into an encoder and output.

impl<W, E, P, T> EncodeOption<ServerEnd<P, W>, E> for ServerEnd<P, T>

where P: 'static, T: EncodeOption<W, E>, W: Constrained<Constraint = ()>, E: ?Sized,

fn encode_option( this: Option<ServerEnd<P, T>>, encoder: &mut E, out: &mut MaybeUninit<ServerEnd<P, W>>, constraint: (), ) -> Result<(), EncodeError>

Encodes this optional value into an encoder and output.

impl<P, T, U> FromWire<ServerEnd<P, U>> for ServerEnd<P, T>

where T: FromWire<U>,

fn from_wire(wire: ServerEnd<P, U>) -> ServerEnd<P, T>

Converts the given wire to this type.

const COPY_OPTIMIZATION: CopyOptimization<W, Self> = _

Whether the conversion from W to Self is equivalent to copying the raw bytes of W.

impl<P, T, U> FromWireOption<ServerEnd<P, U>> for ServerEnd<P, T>

where P: 'static, T: FromWireOption<U>, U: Wire,

fn from_wire_option(wire: ServerEnd<P, U>) -> Option<ServerEnd<P, T>>

Converts the given wire to an option of this type.

impl<P, T, U> FromWireOptionRef<ServerEnd<P, U>> for ServerEnd<P, T>

where P: 'static, T: FromWireOptionRef<U>, U: Wire,

fn from_wire_option_ref(wire: &ServerEnd<P, U>) -> Option<ServerEnd<P, T>>

Converts the given wire reference to an option of this type.

impl<P, T, U> FromWireRef<ServerEnd<P, U>> for ServerEnd<P, T>

where T: FromWireRef<U>,

fn from_wire_ref(wire: &ServerEnd<P, U>) -> ServerEnd<P, T>

Converts the given wire reference to this type.

impl<P, T> IntoNatural for ServerEnd<P, T>

where T: IntoNatural,

type Natural = ServerEnd<P, <T as IntoNatural>::Natural>

A good default type for this wire type to convert into.

fn into_natural(self) -> Self::Natural

Converts this type into its natural equivalent.

impl<P, T> PartialEq for ServerEnd<P, T>

where P: PartialEq, T: PartialEq,

fn eq(&self, other: &ServerEnd<P, T>) -> 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<P, T> Wire for ServerEnd<P, T>

where P: 'static, T: Wire,

type Owned<'de> = ServerEnd<P, <T as Wire>::Owned<'de>>

The owned wire type, restricted to the 'de lifetime.

fn zero_padding(out: &mut MaybeUninit<ServerEnd<P, T>>)

Writes zeroes to the padding for this type, if any.

impl<P, T> Send for ServerEnd<P, T>

where T: Send,

impl<P, T> StructuralPartialEq for ServerEnd<P, T>

impl<P, T> Sync for ServerEnd<P, T>

where T: Sync,

impl<P, T> Unconstrained for ServerEnd<P, T>

where T: Constrained<Constraint = ()>,