pupil_recording_interface.Pipeline

class pupil_recording_interface.Pipeline(steps, context=None)

Bases: object

Pipeline for different processing steps.

__init__(steps, context=None)

Constructor.

Parameters

• steps (iterable of BaseProcess) – Processing steps for this pipeline.

• context (BaseStream, optional) – The stream this pipeline is attached to, if applicable.

Methods

__init__(steps[, context])	Constructor.
from_config(config, device[, folder])	Create an instance from a StreamConfig.
process(packet[, notifications])	Process new data.
set_context(context)	Set the stream this pipeline is attached to.
start()	Start the pipeline.
stop()	Stop the pipeline.

Attributes

listen_for

classmethod from_config(config, device, folder=None)

Create an instance from a StreamConfig.

process(packet, notifications=None)

Process new data.

set_context(context)

Set the stream this pipeline is attached to.

start()

Start the pipeline.

stop()

Stop the pipeline.