Struct parity_tokio_ipc::Endpoint

pub struct Endpoint { /* fields omitted */ }

Endpoint for IPC transport

Examples

extern crate tokio;
extern crate futures;
extern crate parity_tokio_ipc;

use parity_tokio_ipc::{Endpoint, dummy_endpoint};
use futures::{future, Future, Stream};

fn main() {
    let runtime = tokio::runtime::Runtime::new()
        .expect("Error creating tokio runtime");
    let handle = runtime.reactor();
    let endpoint = Endpoint::new(dummy_endpoint());
    let server = endpoint.incoming(handle)
        .expect("failed to open up a new pipe/socket")
        .for_each(|(_stream, _remote_id)| {
            println!("Connection received");
            future::ok(())
        })
        .map_err(|err| panic!("Endpoint connection error: {:?}", err));
    // ... run server etc.
}

Methods

impl Endpoint

pub fn incoming(self, handle: &Handle) -> Result<Incoming>

Stream of incoming connections

pub fn set_security_attributes(
    &mut self,
    security_attributes: SecurityAttributes
)

Set security attributes for the connection

pub fn path(&self) -> &str

Returns the path of the endpoint.

pub fn new(path: String) -> Self

New IPC endpoint at the given path