Skip to main content

ArrayStreamIPC

vortex_ipc::stream

Trait ArrayStreamIPC 

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

A trait for converting an ArrayStream into IPC streams.

Required Methods§

Source

fn into_ipc(self, session: &VortexSession) -> ArrayStreamIPCBytes
where Self: Sized,

Source

fn write_ipc<W: AsyncWrite + Unpin>( self, write: W, session: &VortexSession, ) -> impl Future<Output = VortexResult<W>>
where Self: Sized,

Implementors§

Source§

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