Trait ya_service_bus::connection::CallRequestHandler

pub trait CallRequestHandler {
    type Reply: Stream<Item = Result<ResponseChunk, Error>> + Unpin;
    fn do_call(
        &mut self, 
        request_id: String, 
        caller: String, 
        address: String, 
        data: Vec<u8>
    ) -> Self::Reply;

    fn handle_event(&mut self, caller: String, topic: String, data: Vec<u8>) { ... }
    fn on_disconnect(&mut self) { ... }
}

Associated Types

type Reply: Stream<Item = Result<ResponseChunk, Error>> + Unpin

Required methods

fn do_call(
    &mut self,
    request_id: String,
    caller: String,
    address: String,
    data: Vec<u8>
) -> Self::Reply

Provided methods

fn handle_event(&mut self, caller: String, topic: String, data: Vec<u8>)

fn on_disconnect(&mut self)

Implementations on Foreign Types

impl<R: Stream<Item = Result<ResponseChunk, Error>> + Unpin, F1: FnMut(String, String, String, Vec<u8>) -> R, F2: FnMut(String, String, Vec<u8>)> CallRequestHandler for (F1, F2)

type Reply = R

fn do_call(
    &mut self,
    request_id: String,
    caller: String,
    address: String,
    data: Vec<u8>
) -> Self::Reply

fn handle_event(&mut self, caller: String, topic: String, data: Vec<u8>)

Implementors

impl CallRequestHandler for LocalRouterHandler

impl<R: Stream<Item = Result<ResponseChunk, Error>> + Unpin, F: FnMut(String, String, String, Vec<u8>) -> R> CallRequestHandler for F