Struct DispatchClosure 

pub struct DispatchClosure<C, T, R, H, F>
where
    C: Codec,
    T: ServerTaskDecode<R>,
    R: ServerTaskResp,
    H: FnOnce(T) -> F + Send + Sync + 'static + Clone,
    F: Future<Output = Result<(), ()>> + Send + 'static,
{ /* private fields */ }

A Dispatch trait impl with a closure, only useful for writing tests.

NOTE: The closure requires Clone.

Example

use razor_stream::server::{ServerFacts, Dispatch};
impl ServerFacts for YourServer {

    ...

    #[inline]
    fn new_dispatcher(&self) -> impl Dispatch<Self::RespTask> {
        let dispatch_f = move |task: FileServerTask| {
            async move {
                todo!();
            }
        }
        return DispatchClosure::<MsgpCodec, YourServerTask, Self::RespTask, _, _>::new(
            dispatch_f,
        );
    }
}

Implementations

impl<C, T, R, H, F> DispatchClosure<C, T, R, H, F>

where C: Codec, T: ServerTaskDecode<R>, R: ServerTaskResp, H: FnOnce(T) -> F + Send + Sync + 'static + Clone, F: Future<Output = Result<(), ()>> + Send + 'static,

pub fn new(task_handle: H) -> Self

Trait Implementations

impl<C, T, R, H, F> Clone for DispatchClosure<C, T, R, H, F>

where C: Codec, T: ServerTaskDecode<R>, R: ServerTaskResp, H: FnOnce(T) -> F + Send + Sync + 'static + Clone, F: Future<Output = Result<(), ()>> + Send + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C, T, R, H, F> Dispatch for DispatchClosure<C, T, R, H, F>

where C: Codec, T: ServerTaskDecode<R>, R: ServerTaskResp, H: FnOnce(T) -> F + Send + Sync + 'static + Clone, F: Future<Output = Result<(), ()>> + Send + 'static,

type Codec = C

type RespTask = R

async fn dispatch_req<'a>( &'a self, codec: &Arc<Self::Codec>, req: RpcSvrReq<'a>, noti: RespNoti<R>, ) -> Result<(), ()>

Decode and handle the request, called from the connection reader coroutine.