Struct erdos::dataflow::stream::internal_read_stream::InternalReadStream

pub struct InternalReadStream<D: Data> { /* fields omitted */ }

Methods

impl<D: Data> InternalReadStream<D>

pub fn new() -> Self

Create a stream into which we can write data.

pub fn new_with_id_name(id: StreamId, name: &str) -> Self

pub fn get_id(&self) -> StreamId

pub fn get_name(&self) -> &str

pub fn from_endpoint(
    recv_endpoint: RecvEndpoint<Message<D>>,
    id: StreamId
) -> Self

pub fn add_callback<F: 'static + Fn(Timestamp, D)>(&mut self, callback: F)

Add a callback to be invoked when the stream receives a message.

pub fn add_watermark_callback<F: 'static + Fn(&Timestamp)>(
    &mut self,
    callback: F
)

Add a callback to be invoked after the stream received, and the operator processed all the messages with a timestamp.

pub fn add_state<S: State>(
    &mut self,
    state: S
) -> Rc<RefCell<InternalStatefulReadStream<D, S>>>

Returns a new instance of the stream with state associated to it.

Trait Implementations

impl<D: Data> Default for InternalReadStream<D>

fn default() -> Self

Returns the "default value" for a type.

impl<D: Data> EventMakerT for InternalReadStream<D>

type EventDataType = D

fn get_id(&self) -> StreamId

Returns the id of the stream.

fn make_events(&self, msg: Message<Self::EventDataType>) -> Vec<OperatorEvent>

Returns the vector of events that a message receipt generates.

impl<D: Data> From<InternalReadStream<D>> for ReadStream<D>

fn from(internal_stream: InternalReadStream<D>) -> Self

Performs the conversion.

impl<D: Data> ReadStreamT for InternalReadStream<D>

type DataType = D

fn get_id(&self) -> StreamId

Returns the id of the stream.

fn try_read(&mut self) -> Option<Message<D>>

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).

fn read(&mut self) -> Option<Message<D>>

Blocking read. Returns None if the stream doesn't have a receive endpoint.