Struct web3::transports::ipc::Ipc [−][src]
pub struct Ipc { /* fields omitted */ }
Unix Domain Sockets (IPC) transport
Methods
impl Ipc
[src]
impl Ipc
pub fn new<P>(path: P) -> Result<(EventLoopHandle, Self)> where
P: AsRef<Path>,
[src]
pub fn new<P>(path: P) -> Result<(EventLoopHandle, Self)> where
P: AsRef<Path>,
Create new IPC transport with separate event loop. NOTE: Dropping event loop handle will stop the transport layer!
pub fn with_event_loop<P>(path: P, handle: &Handle) -> Result<Self> where
P: AsRef<Path>,
[src]
pub fn with_event_loop<P>(path: P, handle: &Handle) -> Result<Self> where
P: AsRef<Path>,
Create new IPC transport within existing Event Loop.
Trait Implementations
impl Debug for Ipc
[src]
impl Debug for Ipc
fn fmt(&self, f: &mut Formatter) -> Result
[src]
fn fmt(&self, f: &mut Formatter) -> Result
Formats the value using the given formatter. Read more
impl Clone for Ipc
[src]
impl Clone for Ipc
fn clone(&self) -> Ipc
[src]
fn clone(&self) -> Ipc
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0[src]
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
impl Transport for Ipc
[src]
impl Transport for Ipc
type Out = IpcTask<fn(_: 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)
[src]
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
[src]
fn send(&self, id: RequestId, request: Call) -> Self::Out
Execute prepared RPC call.
fn execute(&self, method: &str, params: Vec<Value>) -> Self::Out
[src]
fn execute(&self, method: &str, params: Vec<Value>) -> Self::Out
Execute remote method with given parameters.
impl BatchTransport for Ipc
[src]
impl BatchTransport for Ipc
type Batch = IpcTask<fn(_: 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)>,
[src]
fn send_batch<T>(&self, requests: T) -> Self::Batch where
T: IntoIterator<Item = (RequestId, Call)>,
Sends a batch of prepared RPC calls.
impl DuplexTransport for Ipc
[src]
impl DuplexTransport for Ipc
type NotificationStream = Box<Stream<Item = Value, Error = Error> + Send + 'static>
The type of stream this transport returns
fn subscribe(&self, id: &SubscriptionId) -> Self::NotificationStream
[src]
fn subscribe(&self, id: &SubscriptionId) -> Self::NotificationStream
Add a subscription to this transport
fn unsubscribe(&self, id: &SubscriptionId)
[src]
fn unsubscribe(&self, id: &SubscriptionId)
Remove a subscription from this transport