Trait exocore_transport::transport::TransportServiceHandle

pub trait TransportServiceHandle: Future<Output = ()> + Send + Unpin + 'static {
    type Sink: Sink<OutEvent, Error = Error> + Send + Unpin + 'static;
    type Stream: Stream<Item = InEvent> + Send + Unpin + 'static;

    // Required methods
    fn on_started(&self) -> TransportHandleOnStart;
    fn get_sink(&mut self) -> Self::Sink;
    fn get_stream(&mut self) -> Self::Stream;
}

Handle to a transport to be used by a service of a cell.

Required Associated Types

type Sink: Sink<OutEvent, Error = Error> + Send + Unpin + 'static

type Stream: Stream<Item = InEvent> + Send + Unpin + 'static

Required Methods

fn on_started(&self) -> TransportHandleOnStart

fn get_sink(&mut self) -> Self::Sink

fn get_stream(&mut self) -> Self::Stream

Implementors

impl TransportServiceHandle for HttpTransportServiceHandle

type Sink = MpscHandleSink

type Stream = MpscHandleStream

impl TransportServiceHandle for Libp2pTransportServiceHandle

type Sink = SinkMapErr<Sender<OutEvent>, fn(_: SendError) -> Error>

type Stream = Receiver<InEvent>

impl<TLeft, TRight> TransportServiceHandle for EitherTransportServiceHandle<TLeft, TRight>where TLeft: TransportServiceHandle, TRight: TransportServiceHandle,

type Sink = Box<dyn Sink<OutEvent, Error = Error> + Send + Unpin + 'static, Global>

type Stream = Box<dyn Stream<Item = InEvent> + Send + Unpin + 'static, Global>