morpheus.stages.output.in_memory_sink_stage

InMemorySinkStage(c)

Collects incoming messages into a list that can be accessed after the pipeline is complete.