Dataflow

onyx.dataflow – Support for dataflow elements

>>> processor()
Traceback (most recent call last):
  ...
  File "<stdin>", line 31, in __repr__
NotImplementedError: subclass must override this method

class onyx.dataflow.processor(*_)

Bases: object

Baseclass for objects implementing the processor interface.

configure(**kwargs)

process_one(item)

process_some(items)

Process each of the elements of ‘items’. Return a list of results.

send_many(inputs)

Dataflow Modules

• onyx.dataflow.cfg – Work with CFG grammars.
• onyx.dataflow.combine_processor – Creating network of processors and useful processor wrappers.
• onyx.dataflow.composecfg – Proof of concept of composing CFGs.
• onyx.dataflow.graph – Nestable graph-based dataflow support.
• onyx.dataflow.simplecfg – Tools for working with CFG grammars.
• onyx.dataflow.source – Source elements that push data into a dataflow network
• onyx.dataflow.streamprocess – A base class and some simple subclasses for dataflow processing.
• onyx.dataflow.join – Join processing elements, that is, elements which can be sent data from
• onyx.dataflow.command – A dataflow processing element for executing command line subprocesses
• onyx.dataflow.framesynchronous – Pedagogical outline of frame synchronous decoding