Morelia.Stream package

Subpackages

• Morelia.Stream.sink package
  • Submodules
  • Morelia.Stream.sink.csv_sink module
    • CSVSink
      • CSVSink.file_path
      • CSVSink.get_dict()
  • Morelia.Stream.sink.edf_sink module
    • EDFSink
      • EDFSink.file_path
      • EDFSink.get_dict()
      • EDFSink.pod
  • Morelia.Stream.sink.influx_sink module
    • InfluxSink
      • InfluxSink.api_token
      • InfluxSink.bucket
      • InfluxSink.close()
      • InfluxSink.flush()
      • InfluxSink.get_dict()
      • InfluxSink.measurement
      • InfluxSink.open()
      • InfluxSink.org
      • InfluxSink.url
  • Morelia.Stream.sink.sink_interface module
    • SinkInterface
      • SinkInterface.flush()
      • SinkInterface.get_dict()
  • Sink performance and GIL overview
  • Module contents

Submodules

Morelia.Stream.data_flow module

Morelia.Stream.source module

Functions for getting streaming data from a POD device using ReactiveX (RxPy).

Morelia.Stream.source.get_data(duration, manual_stop_event, pod, sinks)

Streams data from the POD device. The data drops about every 1 second. Streaming will continue until a “stop streaming” packet is recieved.

Parameters:

• duration (float) – How long to stream data for.

• manual_stop_event (Event) – Used to synchronize multiple get_data operations in a flowgraph. When a flowgraph is told to stop collecting, this event is set which stops the loop within the reactivex operator that is collecting data.

• pod (AcquisitionDevice) – The device to collect data from.

Return type:

None

Morelia.Stream.source.get_data_wrapper(duration_sec, manual_stop_event, source_class, source_dict, sinks_list)

Morelia.Stream.source.make_packet_putter(read_queue)

Module contents