Method on_close

src/react/observable.py:202–203 · view source on GitHub ↗

(self)

Source from the content-addressed store, hash-verified

200	self.buffer_chunks.append(data)
201
202	def on_close(self):
203	self.source_closed = True
204
205	def subscribe(self, observer):
206	with self.subscriber_lock:

nothing calls this directly

no outgoing calls

no test coverage detected