bluesky.bundlers.RunBundler.collect

async RunBundler.collect(msg)[source]

Collect data cached by a flyer and emit documents.

Expect message object is

Msg(‘collect’, collect_obj) Msg(‘collect’, flyer_object, stream=True, return_payload=False, name=’stream_name’)