Struct Endpoint

pub struct Endpoint { /* private fields */ }

Endpoint for IPC transport

Examples

use parity_tokio_ipc::{Endpoint, dummy_endpoint};
use futures::{future, Future, Stream, StreamExt};
use tokio::runtime::Runtime;

fn main() {
   	let mut runtime = Runtime::new().unwrap();
    let mut endpoint = Endpoint::new(dummy_endpoint());
    let server = endpoint.incoming()
        .expect("failed to open up a new pipe/socket")
        .for_each(|_stream| {
            println!("Connection received");
            futures::future::ready(())
        });
   	runtime.block_on(server)
}

Endpoint implementation for windows

Implementations

impl Endpoint

pub fn incoming( self, ) -> Result<impl Stream<Item = Result<impl AsyncRead + AsyncWrite>> + 'static>

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 async fn connect<P: AsRef<Path>>(path: P) -> Result<Connection>

Make new connection using the provided path and running event pool.

pub fn new(path: String) -> Self

New IPC endpoint at the given path