Struct futuresdr::runtime::stream_io::StreamOutput

pub struct StreamOutput { /* private fields */ }

Implementations

impl StreamOutput

pub fn new<T: Any>(name: &str) -> StreamOutput

pub fn item_size(&self) -> usize

pub fn type_id(&self) -> TypeId

pub fn name(&self) -> &str

pub fn init(&mut self, writer: BufferWriter)

pub fn add_tag(&mut self, index: usize, tag: Tag)

pub fn add_tag_abs(&mut self, index: usize, tag: Tag)

pub fn add_reader(
&mut self,
reader_inbox: Sender<BlockMessage>,
reader_port: usize
) -> BufferReader

pub fn try_as<T: 'static>(&mut self) -> Option<&mut T>

pub fn produce(&mut self, amount: usize)

pub fn slice<T>(&mut self) -> &'static mut [T]

pub fn slice_unchecked<T>(&mut self) -> &'static mut [T]

pub fn produced(&self) -> usize

pub async fn notify_finished(&mut self)

pub fn finish(&mut self)

pub fn finished(&self) -> bool

Trait Implementations

impl Debug for StreamOutput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.