Method subscribe

src/process_handler.py:78–79 · view source on GitHub ↗

(self)

Source from the content-addressed store, hash-verified

76	}
77
78	def subscribe(self):
79	return self._output_queue # return the queue for external subscription
80
81	async def get_stream(self):
82	while True:

nothing calls this directly

no outgoing calls

no test coverage detected