Package com.google.adk.workflow

Class JoinNode

java.lang.Object

com.google.adk.workflow.BaseNode

com.google.adk.workflow.JoinNode

All Implemented Interfaces:

Node

@Experimental
public final class JoinNode
extends BaseNode

A node that waits for every predecessor to complete, then outputs their outputs keyed by predecessor name. Route each predecessor into the join every time it completes: one that routes elsewhere still counts as complete, and if it completes last, the join never runs.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	JoinNode.Builder	Builder for JoinNode.

Method Summary

Modifier and Type	Method	Description
static JoinNode.Builder	builder()
boolean	requiresAllPredecessors()	Returns true if the node runs only once every predecessor has completed, receiving all their outputs keyed by node name, as a fan-in node does.
io.reactivex.rxjava3.core.Flowable<?>	runNode(Context context, @Nullable Object nodeInput)	Outputs its input unchanged, or nothing when the input is null.

Methods inherited from class com.google.adk.workflow.BaseNode

config, description, inputSchema, name, outputSchema, rerunOnResume, stateSchema, waitForOutput

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static JoinNode.Builder builder()

requiresAllPredecessors

public boolean requiresAllPredecessors()

Description copied from interface: Node

Returns true if the node runs only once every predecessor has completed, receiving all their outputs keyed by node name, as a fan-in node does.

runNode

public io.reactivex.rxjava3.core.Flowable<?> runNode(Context context,
 @Nullable Object nodeInput)

Outputs its input unchanged, or nothing when the input is null.