View Source Skitter.BIO (Skitter v0.7.1)

Inserts a Skitter.BIO.Filter Skitter.DSL.Workflow.node/2 in the workflow. The argument passed to this macro is passed as an argument to Skitter.BIO.Filter, other options (as:, with:) should be passed as a second, optional argument.

flat_map(func, opts \\ [])

(macro)

Skitter.BIO.FlatMap node.

Like map/2, but with Skitter.BIO.FlatMap.

keyed_reduce(key_fn, red_fn, initial, opts \\ [])

(macro)

Skitter.BIO.KeyedReduce node.

Inserts a Skitter.BIO.KeyedReduce Skitter.DSL.Workflow.node/2 in the workflow. The key_fn, red_fn and initial arguments passed to this macro are passed as arguments to Skitter.BIO.KeyedReduce. Other options (as:, with:) can be passed as a fourth argument.

map(func, opts \\ [])

(macro)

Skitter.BIO.Map node.

Inserts a Skitter.BIO.Map Skitter.DSL.Workflow.node/2 in the workflow. The argument passed to this macro is passed as an argument to Skitter.BIO.Map, other options (as:, with:) should be passed as a second, optional argument.

msg_source(opts \\ [])

(macro)

Message source node.

Inserts a Skitter.BIO.MessageSource node in the workflow. Any options are passed to the workflow.

print(label \\ nil, opts \\ [])

(macro)

Skitter.BIO.Print node.

Insert a Skitter.BIO.Print node in the workflow. The argument passed to this macro is passed as the print label described in the operation documentation. Workflow options (as, with) can be passed as the optional second argument.

send_sink(pid \\ quote do self() end, opts \\ [])

(macro)

Skitter.BIO.Send node.

Insert a Skitter.BIO.Send sink in the workflow. The argument passed to this macro is passed as the pid described in the operation documentation. Workflow options (as, with) can be passed as the optional second argument. When no argument is provided, self() will be used.

stream_source(enum, opts \\ [])

(macro)

Stream source node.

Inserts a Skitter.BIO.StreamSource node in the workflow. The provided enum is passed as an argument to Skitter.BIO.StreamSource. opts are passed as options to the workflow.

tcp_source(address, port, opts \\ [])

(macro)

Tcp source node.

Inserts a Skitter.BIO.TCPSource node in the workflow. The address and ports passed to this argument will be passed as arguments to Skitter.BIO.TCPSource. Provided options are passed to the workflow.