pub struct PubSubHandler<T: PubSubMetadata, S: Middleware<T> = Noop> { /* private fields */ }
Expand description

Publish-Subscribe extension of IoHandler.

Implementations

Creates new PubSubHandler

Adds new subscription.

Methods from Deref<Target = MetaIoHandler<T, S>>

Adds an alias to a method.

Adds new supported asynchronous method

Adds new supported notification

Adds new supported asynchronous method with metadata support.

Adds new supported notification with metadata support.

Extend this MetaIoHandler with methods defined elsewhere.

Handle given request synchronously - will block until response is available. If you have any asynchronous methods in your RPC it is much wiser to use handle_request instead and deal with asynchronous requests in a non-blocking fashion.

Handle given request asynchronously.

Handle deserialized RPC request.

Handle single call asynchronously.

Returns an iterator visiting all methods in arbitrary order.

Trait Implementations

Returns the “default value” for a type. Read more

The resulting type after dereferencing.

Dereferences the value.

Mutably dereferences the value.

Performs the conversion.

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.