Struct NamedStream 

pub struct NamedStream<S: StreamEffect>(/* private fields */);

Implementations

impl<S: StreamEffect> NamedStream<S>

pub fn spawn_scope_stream( in_scope: Entity, out_scope: Entity, commands: &mut Commands<'_, '_>, ) -> (InputSlot<S::Input>, Output<S::Output>)

pub fn spawn_workflow_stream( name: impl Into<Cow<'static, str>>, builder: &mut Builder<'_, '_, '_>, ) -> InputSlot<S::Input>

pub fn spawn_node_stream( name: impl Into<Cow<'static, str>>, source: Entity, map: &mut StreamTargetMap, builder: &mut Builder<'_, '_, '_>, ) -> Output<S::Output>

pub fn take_stream( name: impl Into<Cow<'static, str>>, source: Entity, map: &mut StreamTargetMap, commands: &mut Commands<'_, '_>, ) -> Receiver<S::Output>

pub fn collect_stream( name: impl Into<Cow<'static, str>>, source: Entity, target: Entity, map: &mut StreamTargetMap, commands: &mut Commands<'_, '_>, )

pub fn make_stream_channel( name: impl Into<Cow<'static, str>>, inner: &Arc<InnerChannel>, world: &World, ) -> NamedStreamChannel<S>

pub fn make_stream_buffer( target_map: Option<&StreamTargetMap>, ) -> NamedStreamBuffer<S::Input>

pub fn process_stream_buffer( name: impl Into<Cow<'static, str>>, buffer: NamedStreamBuffer<S::Input>, source: Entity, session: Entity, unused: &mut UnusedStreams, world: &mut World, roster: &mut OperationRoster, ) -> OperationResult

pub fn defer_buffer( name: impl Into<Cow<'static, str>>, buffer: NamedStreamBuffer<S::Input>, source: Entity, session: Entity, commands: &mut Commands<'_, '_>, )