snsary.streams.async_stream

Creates a thread for each Output that subscribes to. Any Readings are published to a separate queue for each Output, with the thread logging any errors from relaying to it. Using AsyncStream helps avoid issues due to flakey or time-consuming Outputs.

Module Contents

class snsary.streams.async_stream.AsyncStream

Bases: snsary.streams.stream.Stream

publish(reading)

subscribe(output)