(&self, py: Python, message: Message)
| 78 | /// Sends a message to the WebSocket. |
| 79 | #[pyo3(signature = (message))] |
| 80 | pub fn send(&self, py: Python, message: Message) -> PyResult<()> { |
| 81 | py.allow_threads(|| { |
| 82 | pyo3_async_runtimes::tokio::get_runtime() |
| 83 | .block_on(WebSocket::_send(self.0.sender(), message)) |
| 84 | }) |
| 85 | } |
| 86 | |
| 87 | /// Closes the WebSocket connection. |
| 88 | #[pyo3(signature = (code=None, reason=None))] |