bluesky.bundlers.RunBundler.collect

async RunBundler.collect(msg)

Collect data cached by a flyer and emit documents.

Expect message object is

Msg(‘collect’, collect_obj, collect_obj_2, …, stream=True,

return_payload=True, name=’stream_name’)

Where there must be at least one collect object. If multiple are used they must obey the WritesStreamAssets protocol.