Struct ckb_sdk::pubsub::Client

pub struct Client<T> { /* private fields */ }

General rpc subscription client

Implementations

impl<T> Client<T>where
    T: AsyncWrite + AsyncRead + Unpin,

pub fn new(io: T) -> Client<T>

New a pubsub rpc client

pub async fn subscribe<F: for<'de> Deserialize<'de>>(
    self,
    name: &str
) -> Result<Handle<T, F>>

Subscription a topic

pub async fn subscribe_list<F: for<'de> Deserialize<'de>, I: Iterator<Item = H>, H: AsRef<str>>(
    self,
    name_list: I
) -> Result<Handle<T, F>>

Subscription topics