Struct web3::transports::ws::WebSocket

pub struct WebSocket { /* fields omitted */ }

WebSocket transport

Implementations

impl WebSocket

pub async fn new<'_>(url: &'_ str) -> Result<Self>

Create new WebSocket transport.

Trait Implementations

impl BatchTransport for WebSocket

type Batch = Response<Vec<Result<Value>>, fn(_: Result<Vec<Result<Value>>>) -> Result<Vec<Result<Value>>>>

The type of future this transport returns when a call is made.

fn send_batch<T>(&self, requests: T) -> Self::Batch where
    T: IntoIterator<Item = (RequestId, Call)>, 

Sends a batch of prepared RPC calls.

impl Clone for WebSocket

fn clone(&self) -> WebSocket

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocket

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

Formats the value using the given formatter.

impl DuplexTransport for WebSocket

type NotificationStream = UnboundedReceiver<Value>

The type of stream this transport returns

fn subscribe(&self, id: SubscriptionId) -> Result<Self::NotificationStream>

Add a subscription to this transport

fn unsubscribe(&self, id: SubscriptionId) -> Result

Remove a subscription from this transport

impl Transport for WebSocket

type Out = Response<Value, fn(_: Result<Vec<Result<Value>>>) -> Result<Value>>

The type of future this transport returns when a call is made.

fn prepare(&self, method: &str, params: Vec<Value>) -> (RequestId, Call)

Prepare serializable RPC call for given method with parameters.

fn send(&self, id: RequestId, request: Call) -> Self::Out

Execute prepared RPC call.

fn execute(&self, method: &str, params: Vec<Value>) -> Self::Out

Execute remote method with given parameters.