snsary.streams.func_stream

Publishes zero or more Readings depending on what the specified function returns for a given Reading. This could be nothing, the same reading, or multiple, different readings.

Module Contents

class snsary.streams.func_stream.FuncStream(stream, function=lambda reading: ...)

Bases: snsary.streams.simple_stream.SimpleStream

publish(reading)