Trait vortex_ipc::stream::ArrayStreamIPC

pub trait ArrayStreamIPC {
    // Required methods
    fn into_ipc(self) -> ArrayStreamIPCBytes
       where Self: Sized;
    fn write_ipc<W: AsyncWrite + Unpin>(
        self,
        write: W,
    ) -> impl Future<Output = VortexResult<W>>
       where Self: Sized;
}

A trait for convering an [ArrayStream] into IPC streams.

Required Methods

fn into_ipc(self) -> ArrayStreamIPCBytes

where Self: Sized,

fn write_ipc<W: AsyncWrite + Unpin>( self, write: W, ) -> impl Future<Output = VortexResult<W>>

where Self: Sized,

Implementors

impl<S: ArrayStream + 'static> ArrayStreamIPC for S