Struct ExternalProcess

pub struct ExternalProcess<'a, P> { /* private fields */ }

Implementations

impl<'a, P> ExternalProcess<'a, P>

pub fn source_external_bytes<L: Location<'a> + NoTick>( &self, to: &L, ) -> (ExternalBytesPort, Stream<Bytes, L, Unbounded>)

pub fn source_external_bincode<L: Location<'a> + NoTick, T: Serialize + DeserializeOwned>( &self, to: &L, ) -> (ExternalBincodeSink<T>, Stream<T, L, Unbounded>)

Trait Implementations

impl<'a, P1, E2> CanSend<'a, ExternalProcess<'a, E2>> for Process<'a, P1>

type In<T> = T

type Out<T> = T

type OutStrongestOrder<InOrder> = InOrder

Given the ordering guarantees of the input, determines the strongest possible ordering guarantees of the output.

fn is_demux() -> bool

fn tagged_type() -> Option<Type>

impl<P> Clone for ExternalProcess<'_, P>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, P> Location<'a> for ExternalProcess<'a, P>

type Root = ExternalProcess<'a, P>

fn root(&self) -> Self::Root

fn id(&self) -> LocationId

fn flow_state(&self) -> &FlowState

fn is_top_level() -> bool

fn next_node_id(&self) -> usize

fn new_node_metadata<T>(&self) -> HydroIrMetadata