bluesky.bundlers.RunBundler.monitor

async RunBundler.monitor(msg)[source]

Monitor a signal. Emit event documents asynchronously.

A descriptor document is emitted immediately. Then, a closure is defined that emits Event documents associated with that descriptor from a separate thread. This process is not related to the main bundling process (create/read/save).

Expected message object is:

Msg('monitor', obj, **kwargs)
Msg('monitor', obj, name='event-stream-name', **kwargs)

where kwargs are passed through to obj.subscribe()