(self, data)
| 458 | self._readable = False |
| 459 | |
| 460 | def push(self, data): |
| 461 | sabs = self.out_buffer_size |
| 462 | if len(data) > sabs: |
| 463 | chunks = [] |
| 464 | for i in range(0, len(data), sabs): |
| 465 | chunks.append(data[i:i + sabs]) |
| 466 | else: |
| 467 | chunks = [data] |
| 468 | |
| 469 | with self.deque_lock: |
| 470 | self.deque.extend(chunks) |
| 471 | self._writable = True |
| 472 | _global_loop.wake_loop() |
| 473 | |
| 474 | def writable(self): |
| 475 | return self._writable |