Struct ethers_providers::Ws

pub struct Ws { /* fields omitted */ }

A JSON-RPC Client over Websockets.

use ethers_providers::Ws;

let ws = Ws::connect("wss://localhost:8545").await?;

Implementations

impl Ws

pub fn new<S: 'static>(ws: S) -> Self where
    S: Send + Sync + Stream<Item = Result<Message, Error>> + Sink<Message, Error = Error> + Unpin, 

Initializes a new WebSocket Client, given a Stream/Sink Websocket implementer. The websocket connection must be initiated separately.

pub fn ready(&self) -> bool

Returns true if the WS connection is active, false otherwise

pub async fn connect(
    url: impl IntoClientRequest + Unpin
) -> Result<Self, ClientError>

Initializes a new WebSocket Client

Trait Implementations

impl Clone for Ws

fn clone(&self) -> Ws

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Ws

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl JsonRpcClient for Ws

type Error = ClientError

A JSON-RPC Error

fn request<'life0, 'life1, 'async_trait, T: Serialize + Send + Sync, R: DeserializeOwned>(
    &'life0 self,
    method: &'life1 str,
    params: T
) -> Pin<Box<dyn Future<Output = Result<R, ClientError>> + Send + 'async_trait>> where
    T: 'async_trait,
    R: 'async_trait,
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Sends a request with the provided JSON-RPC and parameters serialized as JSON

impl PubsubClient for Ws

type NotificationStream = UnboundedReceiver<Value>

The type of stream this transport returns

fn subscribe<T: Into<U256>>(
    &self,
    id: T
) -> Result<Self::NotificationStream, ClientError>

Add a subscription to this transport

fn unsubscribe<T: Into<U256>>(&self, id: T) -> Result<(), ClientError>

Remove a subscription from this transport