Module pubsub 

Re-exports

use crate::RpcHandler; 🔒

use crate::error::RequestError; 🔒

use crate::handler::handle_request; 🔒

use anvil_rpc::error::RpcError; 🔒

use anvil_rpc::request::Id; 🔒

use anvil_rpc::request::Request; 🔒

use anvil_rpc::response::Response; 🔒

use anvil_rpc::response::ResponseResult; 🔒

use futures::FutureExt; 🔒

use futures::Sink; 🔒

use futures::SinkExt; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use parking_lot::Mutex; 🔒

use serde::de::DeserializeOwned; 🔒

use std::collections::VecDeque; 🔒

use std::fmt; 🔒

use std::hash::Hash; 🔒

use std::hash::Hash; 🔒

use std::pin::Pin; 🔒

use std::sync::Arc; 🔒

use std::task::Context; 🔒

use std::task::Poll; 🔒

Structs

ContextAwareHandler 🔒

A compatibility helper type to use common RpcHandler functions

PendingMessages 🔒

Bounded serialized backlog shared by responses and subscription notifications.

PubSubConnection

Represents a connection to a client via websocket

PubSubContext

Contains additional context and tracks subscriptions

Constants

MAX_PENDING_BYTES 🔒

MAX_PENDING_MESSAGES 🔒

Traits

PubSubRpcHandler

The general purpose trait for handling RPC requests and subscriptions

Type Aliases

Subscriptions 🔒