[−][src]Struct erdos::dataflow::stream::extract_stream::ExtractStream
Methods
impl<D> ExtractStream<D> where
D: Data + Deserialize<'a>,
[src]
D: Data + Deserialize<'a>,
pub fn new(node_id: NodeId, read_stream: &ReadStream<D>) -> Self
[src]
pub fn get_id(&self) -> StreamId
[src]
pub fn get_node_id(&self) -> NodeId
[src]
pub fn try_read(&mut self) -> Option<Message<D>>
[src]
Tries to read a message from a channel.
Returns an immutable reference, or None
if no messages are
available at the moment (i.e., non-blocking read).
pub fn read(&mut self) -> Option<Message<D>>
[src]
Blocking read. Returns None
if the stream doesn't have a receive endpoint.
Trait Implementations
impl<D> Send for ExtractStream<D> where
D: Data + Deserialize<'a>,
[src]
D: Data + Deserialize<'a>,
Auto Trait Implementations
impl<D> !RefUnwindSafe for ExtractStream<D>
impl<D> !Sync for ExtractStream<D>
impl<D> Unpin for ExtractStream<D>
impl<D> !UnwindSafe for ExtractStream<D>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> FromPy<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> IntoPy<U> for T where
U: FromPy<T>,
[src]
U: FromPy<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,