(self, datagram, is_end=False)
| 71 | return self._buffer.get(size) |
| 72 | |
| 73 | def send(self, datagram, is_end=False): |
| 74 | data = self._encapsulate(datagram) |
| 75 | self._connection.write(self._stream_id, data, is_end) |
| 76 | |
| 77 | def _add_input(self, data, is_end): |
| 78 | if self._common_add_input(data, is_end): |
no test coverage detected