Struct sig_proxy::middleware::ethereum::signature::prelude::WebSocket

pub struct WebSocket { /* fields omitted */ }

WebSocket transport

Implementations

impl WebSocket

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

Create new WebSocket transport.

Trait Implementations

impl BatchTransport for WebSocket

type Batch = Response<Vec<Result<Value, Error>, Global>, fn(Result<Vec<Result<Value, Error>, Global>, Error>) -> Result<Vec<Result<Value, Error>, Global>, Error>>

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

pub fn send_batch<T>(&self, requests: T) -> <WebSocket as BatchTransport>::Batch where
    T: IntoIterator<Item = (usize, Call)>, 

Sends a batch of prepared RPC calls.

impl Clone for WebSocket

pub fn clone(&self) -> WebSocket

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocket

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

Formats the value using the given formatter.

impl DuplexTransport for WebSocket

type NotificationStream = UnboundedReceiver<Value>

The type of stream this transport returns

pub fn subscribe(
    &self,
    id: SubscriptionId
) -> Result<<WebSocket as DuplexTransport>::NotificationStream, Error>

Add a subscription to this transport

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

Remove a subscription from this transport

impl Transport for WebSocket

type Out = Response<Value, fn(Result<Vec<Result<Value, Error>, Global>, Error>) -> Result<Value, Error>>

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

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

Prepare serializable RPC call for given method with parameters.

pub fn send(&self, id: usize, request: Call) -> <WebSocket as Transport>::Out

Execute prepared RPC call.

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

Execute remote method with given parameters.