Pipe
====

Data processor
--------------
.. automodule:: retentioneering.data_processors_lib.pipe
    :members:

Eventstream
-----------
.. automethod:: retentioneering.eventstream.helpers.pipe_helper.PipeHelperMixin.pipe