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) Msg(‘collect’, flyer_object, stream=True, return_payload=False)