Searched refs:consume_and_terminate (Results 1 – 4 of 4) sorted by relevance
39 def consume_and_terminate(self, value): member in TransformingConsumer40 self._downstream.consume_and_terminate(self._transformation(value))62 def consume_and_terminate(self, value): member in IterableConsumer104 sink.consume_and_terminate(value)141 def consume_and_terminate(self, value): member in ThreadSwitchingConsumer
39 def consume_and_terminate(self, value): member in Consumer
122 def consume_and_terminate(self, value): member in _Callback182 unary_unary_event(request, callback.consume_and_terminate,214 callback.consume_and_terminate,
38 def consume_and_terminate(self, value): member in TestConsumer