Struct ice_core::streaming::StreamProvider

pub struct StreamProvider {
    pub remote: Remote,
    pub tx: Sender<Result<Chunk, Error>>,
}

Fields

remote: Remote

tx: Sender<Result<Chunk, Error>>

Methods

impl StreamProvider

fn new(ev_loop: &Remote) -> (StreamProvider, ChunkReceiver)

fn into_boxed(self) -> Box<StreamProvider>

unsafe fn from_raw_boxed(raw: *mut StreamProvider) -> Box<StreamProvider>

fn send_chunk(&mut self, chunk: &[u8])

fn close(self)