Struct futuresdr::runtime::stream_io::StreamInput
source · pub struct StreamInput { /* private fields */ }
Expand description
Stream input port
Implementations§
source§impl StreamInput
impl StreamInput
sourcepub fn new<T: Any>(name: &str) -> StreamInput
pub fn new<T: Any>(name: &str) -> StreamInput
Create stream input with given name
sourcepub fn try_as<T: 'static>(&mut self) -> Option<&mut T>
pub fn try_as<T: 'static>(&mut self) -> Option<&mut T>
Try to cast buffer reader to specific type
sourcepub fn slice_unchecked<T>(&mut self) -> &'static [T]
pub fn slice_unchecked<T>(&mut self) -> &'static [T]
Get buffer content as slice without checking the type
sourcepub unsafe fn slice_mut<T>(&mut self) -> &'static mut [T]
pub unsafe fn slice_mut<T>(&mut self) -> &'static mut [T]
Returns a mutable slice to the input buffer.
Safety
The block has to be the sole reader for the input buffer.
sourcepub unsafe fn slice_mut_unchecked<T>(&mut self) -> &'static mut [T]
pub unsafe fn slice_mut_unchecked<T>(&mut self) -> &'static mut [T]
Returns a mutable slice to the input buffer.
Safety
The block has to be the sole reader for the input buffer.
Get ItemTags
in buffer
sourcepub fn set_reader(&mut self, reader: BufferReader)
pub fn set_reader(&mut self, reader: BufferReader)
Set the buffer reader
sourcepub async fn notify_finished(&mut self)
pub async fn notify_finished(&mut self)
Notify connected, upstream writer that we are finished
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for StreamInput
impl Send for StreamInput
impl !Sync for StreamInput
impl Unpin for StreamInput
impl !UnwindSafe for StreamInput
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more