Struct jsonrpc_macros::pubsub::Subscriber
[−]
[src]
pub struct Subscriber<T, E = Error> { /* fields omitted */ }
New PUB-SUB subcriber.
Methods
impl<T, E> Subscriber<T, E>[src]
fn new(subscriber: Subscriber) -> Self
Wrap non-typed subscriber.
fn reject(self, error: Error) -> Result<(), ()>
Reject subscription with given error.
fn assign_id(self, id: SubscriptionId) -> Result<Sink<T, E>, ()>
Assign id to this subscriber.
This method consumes Subscriber and returns Sink
if the connection is still open or error otherwise.