def receive_data(self, event):
        size = event.flow_controlled_length
        increment = self._in_window_manager._handle_frame(size)

        # Append the data to the buffer.
        self.data.append(event.data)

        if increment and not self.remote_closed:
            self._conn.increment_flow_control_window(
                increment, stream_id=self.stream_id
            )
            self._send_cb(self._conn.data_to_send())
Externally register for notification when this publishable has received all relevant data.
dataset/ETHPy150Open Lukasa/hyper/hyper/http20/stream.py/Stream.receive_data--crossover with--dataset/ETHPy150Open kuri65536/python-for-android/python-modules/twisted/twisted/spread/publish.py/RemotePublished.callWhenActivated