Struct ReactiveNodeAdapter 

pub struct ReactiveNodeAdapter<R, Change, Context, Action>
where
    Change: Send + Sync + 'static,
    Context: Send + Sync + 'static,
    Action: ActionType + Send + Sync + 'static + Debug,
    R: ReactiveNode<Change, Context, Action> + Send + 'static,
{ /* private fields */ }

An adapter that allows a ReactiveNode to be used as a standard Node. This adapter handles the streaming and change detection.

Implementations

impl<R, Change, Context, Action> ReactiveNodeAdapter<R, Change, Context, Action>

where Change: Send + Sync + 'static, Context: Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Debug, R: ReactiveNode<Change, Context, Action> + Send + 'static,

pub fn new(node: R) -> Self

Create a new adapter for a reactive node

pub fn with_buffer_size(self, size: usize) -> Self

Set the buffer size for the change stream

pub async fn start_watching( &self, ctx: Context, ) -> Result<impl Stream<Item = Action> + Unpin, FloxideError>

Start watching for changes and process them in the background

Trait Implementations

impl<R, Change, Context, Action> Node<Context, Action> for ReactiveNodeAdapter<R, Change, Context, Action>

where Change: Send + Sync + 'static, Context: Clone + Send + Sync + 'static, Action: ActionType + Send + Sync + 'static + Debug, R: ReactiveNode<Change, Context, Action> + Send + 'static,

type Output = Action

The output type produced by this node

fn process<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = Result<NodeOutcome<Self::Output, Action>, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process the node asynchronously

fn id(&self) -> NodeId

Get the unique identifier for this node