User Documentation
RunEngine
RunEngineResult
Dispatcher
RunBundler
RunBundler.collect()
Developer Documentation
Data Collection
Data Access and Management
GitHub Links
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’)