Asynchronously write the given data to this stream. This method returns a `.Future` that resolves (with a result of ``None``) when the write has been completed. The ``data`` argument may be of type `bytes` or `memoryview`. .. versionchanged:: 4.0 Now re
(self, data: Union[bytes, memoryview])
| 508 | return future |
| 509 | |
| 510 | def write(self, data: Union[bytes, memoryview]) -> "Future[None]": |
| 511 | """Asynchronously write the given data to this stream. |
| 512 | |
| 513 | This method returns a `.Future` that resolves (with a result |
| 514 | of ``None``) when the write has been completed. |
| 515 | |
| 516 | The ``data`` argument may be of type `bytes` or `memoryview`. |
| 517 | |
| 518 | .. versionchanged:: 4.0 |
| 519 | Now returns a `.Future` if no callback is given. |
| 520 | |
| 521 | .. versionchanged:: 4.5 |
| 522 | Added support for `memoryview` arguments. |
| 523 | |
| 524 | .. versionchanged:: 6.0 |
| 525 | |
| 526 | The ``callback`` argument was removed. Use the returned |
| 527 | `.Future` instead. |
| 528 | |
| 529 | """ |
| 530 | self._check_closed() |
| 531 | if data: |
| 532 | if isinstance(data, memoryview): |
| 533 | # Make sure that ``len(data) == data.nbytes`` |
| 534 | data = memoryview(data).cast("B") |
| 535 | if ( |
| 536 | self.max_write_buffer_size is not None |
| 537 | and len(self._write_buffer) + len(data) > self.max_write_buffer_size |
| 538 | ): |
| 539 | raise StreamBufferFullError("Reached maximum write buffer size") |
| 540 | self._write_buffer.append(data) |
| 541 | self._total_write_index += len(data) |
| 542 | future = Future() # type: Future[None] |
| 543 | future.add_done_callback(lambda f: f.exception()) |
| 544 | self._write_futures.append((self._total_write_index, future)) |
| 545 | if not self._connecting: |
| 546 | self._handle_write() |
| 547 | if self._write_buffer: |
| 548 | self._add_io_state(self.io_loop.WRITE) |
| 549 | self._maybe_add_error_listener() |
| 550 | return future |
| 551 | |
| 552 | def set_close_callback(self, callback: Optional[Callable[[], None]]) -> None: |
| 553 | """Call the given callback when the stream is closed. |
no test coverage detected