Struct JoinTarget 

pub struct JoinTarget<T: TaskNode<Input = JoinInput<Payload>> + ?Sized, Payload: NodeArg> { /* private fields */ }

A configured join destination for branches that should converge into a join node.

Build a JoinTarget from a join node with NodeId::join, and then register it through Task::register_transition. Users normally do not construct this type directly.

Implementations

impl<T, Payload> JoinTarget<T, Payload>

where T: TaskNode<Input = JoinInput<Payload>> + ?Sized, Payload: NodeArg,

pub fn map<F>(self, map: F) -> MappedJoinTarget<T, Payload, F>

where F: Send + Sync + 'static,

Maps each joining branch output into the payload stored for the join node.

Examples

use swiftide_tasks::{JoinInput, NodeError, Task, Transition};

let mut task = Task::<i32, i32>::new();
let start = task.register_node_fn(|input: &i32| -> Result<i32, NodeError> { Ok(*input) });
let branch = task.register_node_fn(|input: &i32| -> Result<i32, NodeError> { Ok(*input + 1) });
let join = task.register_node_fn(|input: &JoinInput<i32>| -> Result<i32, NodeError> {
    Ok(input.iter().copied().sum())
});

task.starts_with(start);
task.register_transition(start, move |value| {
    Transition::fan_out(&branch, value)
        .join_with(join.join())
})?;
task.register_transition(branch, join.join().map(|value| value * 2))?;

pub fn map_async<F>(self, map: F) -> MappedJoinTarget<T, Payload, F>

where F: Send + Sync + 'static,

Maps each joining branch output asynchronously before storing it for the join node.

Examples

use swiftide_tasks::{JoinInput, NodeError, Task, Transition};

let mut task = Task::<i32, i32>::new();
let start = task.register_node_fn(|input: &i32| -> Result<i32, NodeError> { Ok(*input) });
let branch = task.register_node_fn(|input: &i32| -> Result<i32, NodeError> { Ok(*input + 1) });
let join = task.register_node_fn(|input: &JoinInput<i32>| -> Result<i32, NodeError> {
    Ok(input.iter().copied().sum())
});

task.starts_with(start);
task.register_transition(start, move |value| {
    Transition::fan_out(&branch, value)
        .join_with(join.join())
})?;
task.register_transition_async(branch, join.join().map_async(|value| async move { value * 2 }))?;