Reference another node indirectly. The passed in resolve function can be used to lookup other nodes, with the same logic as above. E.g. the following spec looks up the main output of node "abc" and adds a transformed subscription, which is then used as input for current node.
{ stream: (resolve) =>
resolve("/abc/node").subscribe(map(x => x * 10)) }
Provide an external input stream:
{ stream: () => fromIterable([1,2,3], 500) }
Single value input stream:
{ const: 1 }
{ const: () => 1 }
If the optional xform is given, a subscription with the given transducer is added to the input and then used as input instead.
Specification for a single input, which can be given in different ways:
{ path: "nested.src.path" } { path: ["nested", "src", "path"] }
{ stream: "/node-id/node" } // main node output { stream: "/node-id/outs/foo" } // specific output
resolve
function can be used to lookup other nodes, with the same logic as above. E.g. the following spec looks up the main output of node "abc" and adds a transformed subscription, which is then used as input for current node.{ stream: (resolve) => resolve("/abc/node").subscribe(map(x => x * 10)) }
{ stream: () => fromIterable([1,2,3], 500) }
{ const: 1 } { const: () => 1 }
If the optional
xform
is given, a subscription with the given transducer is added to the input and then used as input instead.