(self, value)
| 78 | return result |
| 79 | |
| 80 | def send(self, value): |
| 81 | self.session.timeline.unfreeze() |
| 82 | self._established.wait() |
| 83 | t = self.session.timeline.mark(("sending", value)) |
| 84 | self._stream.write_json(value) |
| 85 | return t |
| 86 | |
| 87 | def close(self): |
| 88 | sock = self._socket |