Trait actix_wamp::PubSubEndpoint

pub trait PubSubEndpoint {
    type Events: Stream<Item = WampMessage, Error = Error>;
    fn subscribe(&self, uri: &str) -> Self::Events;
}

Associated Types

type Events: Stream<Item = WampMessage, Error = Error>

Loading content...

Required methods

fn subscribe(&self, uri: &str) -> Self::Events

Loading content...

Implementations on Foreign Types

impl<Transport> PubSubEndpoint for Addr<Connection<SplitSink<Transport>>> where
    Transport: Sink<SinkItem = Message, SinkError = ProtocolError> + Stream<Item = Frame, Error = ProtocolError> + 'static, 

type Events = FlattenStream<Flatten<Request<Connection<SplitSink<Transport>>, Subscribe>>>

fn subscribe(&self, uri: &str) -> Self::Events

Loading content...

Implementors

Loading content...