Struct AnonymousStream 

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

A wrapper to turn any StreamEffect into an anonymous (unnamed) stream. This should be used if you want a stream with the same behavior as StreamOf but with some additional side effect. The input and output data types of the stream may be different.

Trait Implementations

impl<S: StreamEffect> StreamEffect for AnonymousStream<S>

type Input = <S as StreamEffect>::Input

type Output = <S as StreamEffect>::Output

fn side_effect( input: Self::Input, request: &mut StreamRequest<'_>, ) -> Result<Self::Output, OperationError>

Specify a side effect that is meant to happen whenever a stream value is sent.

impl<S: StreamEffect> StreamPack for AnonymousStream<S>

type StreamInputPack = InputSlot<<S as StreamEffect>::Input>

type StreamOutputPack = Output<<S as StreamEffect>::Output>

type StreamReceivers = UnboundedReceiver<<S as StreamEffect>::Output>

type StreamChannels = StreamChannel<S>

type StreamBuffers = StreamBuffer<<S as StreamEffect>::Input>

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

fn spawn_workflow_streams( builder: &mut Builder<'_, '_, '_>, ) -> InputSlot<S::Input>

fn spawn_node_streams( source: Entity, map: &mut StreamTargetMap, builder: &mut Builder<'_, '_, '_>, ) -> Output<S::Output>

fn take_streams( source: Entity, map: &mut StreamTargetMap, commands: &mut Commands<'_, '_>, ) -> Receiver<S::Output>

fn collect_streams( source: Entity, target: Entity, map: &mut StreamTargetMap, commands: &mut Commands<'_, '_>, )

fn make_stream_channels( inner: &Arc<InnerChannel>, world: &World, ) -> Self::StreamChannels

fn make_stream_buffers( target_map: Option<&StreamTargetMap>, ) -> StreamBuffer<S::Input>

fn process_stream_buffers( buffer: Self::StreamBuffers, source: Entity, session: Entity, unused: &mut UnusedStreams, world: &mut World, roster: &mut OperationRoster, ) -> OperationResult

fn defer_buffers( buffer: Self::StreamBuffers, source: Entity, session: Entity, commands: &mut Commands<'_, '_>, )

fn set_stream_availability(availability: &mut StreamAvailability)

fn are_streams_available(availability: &StreamAvailability) -> bool

fn into_dyn_stream_input_pack( pack: &mut DynStreamInputPack, inputs: Self::StreamInputPack, )

fn into_dyn_stream_output_pack( pack: &mut DynStreamOutputPack, outputs: Self::StreamOutputPack, )

fn has_streams() -> bool

Are there actually any streams in the pack?