Trait MessageHandler

pub trait MessageHandler<A: Adapter, T>:
    Send
    + Sync
    + 'static {
    // Required method
    fn call(&self, s: Arc<Socket<A>>, v: Value, ack_id: Option<i64>);
}

Define a handler for the connect event. It is implemented for closures with up to 16 arguments. They must implement the FromMessageParts trait or the FromMessage trait for the last one.

• See the message module doc for more details on message handler.
• See the extract module doc for more details on available extractors.

Required Methods

fn call(&self, s: Arc<Socket<A>>, v: Value, ack_id: Option<i64>)

Call the handler with the given arguments

Implementors

impl<A, F> MessageHandler<A, (Sync,)> for F

where F: FnOnce() + Send + Sync + Clone + 'static, A: Adapter,

Empty Sync handler

impl<A, F, Fut> MessageHandler<A, (Async,)> for F

where F: FnOnce() -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter,

Empty Async handler

impl<A, F, M, T1> MessageHandler<A, (Sync, M, T1)> for F

where F: FnOnce(T1) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessage<A, M> + Send,

impl<A, F, M, T1, Fut> MessageHandler<A, (Async, M, T1)> for F

where F: FnOnce(T1) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2> MessageHandler<A, (Sync, M, T1, T2)> for F

where F: FnOnce(T1, T2) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, Fut> MessageHandler<A, (Async, M, T1, T2)> for F

where F: FnOnce(T1, T2) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3> MessageHandler<A, (Sync, M, T1, T2, T3)> for F

where F: FnOnce(T1, T2, T3) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, Fut> MessageHandler<A, (Async, M, T1, T2, T3)> for F

where F: FnOnce(T1, T2, T3) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4> MessageHandler<A, (Sync, M, T1, T2, T3, T4)> for F

where F: FnOnce(T1, T2, T3, T4) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4)> for F

where F: FnOnce(T1, T2, T3, T4) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5)> for F

where F: FnOnce(T1, T2, T3, T4, T5) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5)> for F

where F: FnOnce(T1, T2, T3, T4, T5) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessageParts<A> + Send, T14: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessageParts<A> + Send, T14: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessageParts<A> + Send, T14: FromMessageParts<A> + Send, T15: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessageParts<A> + Send, T14: FromMessageParts<A> + Send, T15: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> MessageHandler<A, (Sync, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16) + Send + Sync + Clone + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessageParts<A> + Send, T14: FromMessageParts<A> + Send, T15: FromMessageParts<A> + Send, T16: FromMessage<A, M> + Send,

impl<A, F, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, Fut> MessageHandler<A, (Async, M, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16)> for F

where F: FnOnce(T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16) -> Fut + Send + Sync + Clone + 'static, Fut: Future<Output = ()> + Send + 'static, A: Adapter, T1: FromMessageParts<A> + Send, T2: FromMessageParts<A> + Send, T3: FromMessageParts<A> + Send, T4: FromMessageParts<A> + Send, T5: FromMessageParts<A> + Send, T6: FromMessageParts<A> + Send, T7: FromMessageParts<A> + Send, T8: FromMessageParts<A> + Send, T9: FromMessageParts<A> + Send, T10: FromMessageParts<A> + Send, T11: FromMessageParts<A> + Send, T12: FromMessageParts<A> + Send, T13: FromMessageParts<A> + Send, T14: FromMessageParts<A> + Send, T15: FromMessageParts<A> + Send, T16: FromMessage<A, M> + Send,