Struct ya_service_bus::connection::LocalRouterHandler
source · pub struct LocalRouterHandler { /* private fields */ }
Implementations§
Trait Implementations§
source§impl CallRequestHandler for LocalRouterHandler
impl CallRequestHandler for LocalRouterHandler
type Reply = Pin<Box<dyn Stream<Item = Result<ResponseChunk, Error>>>>
fn do_call( &mut self, _request_id: String, caller: String, address: String, data: Vec<u8>, no_reply: bool ) -> Self::Reply
fn on_disconnect(&mut self)
fn handle_event(&mut self, caller: String, topic: String, data: Vec<u8>)
source§impl Default for LocalRouterHandler
impl Default for LocalRouterHandler
source§fn default() -> LocalRouterHandler
fn default() -> LocalRouterHandler
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for LocalRouterHandler
impl !RefUnwindSafe for LocalRouterHandler
impl !Send for LocalRouterHandler
impl !Sync for LocalRouterHandler
impl Unpin for LocalRouterHandler
impl !UnwindSafe for LocalRouterHandler
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more