Trait ya_service_bus::connection::CallRequestHandler

pub trait CallRequestHandler {
    type Reply: Stream<Item = Result<ResponseChunk, Error>> + Unpin;

    // Required method
    fn do_call(
        &mut self,
        request_id: String,
        caller: String,
        address: String,
        data: Vec<u8>,
        no_reply: bool
    ) -> Self::Reply;

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

Required 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>, no_reply: bool ) -> 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>, _no_reply: bool ) -> Self::Reply

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

Implementors

impl CallRequestHandler for LocalRouterHandler

type Reply = Pin<Box<dyn Stream<Item = Result<ResponseChunk, Error>>>>

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

type Reply = R