(&self, query: Query)
| 93 | } |
| 94 | |
| 95 | async fn unsubscribe(&self, query: Query) -> Result<(), Error> { |
| 96 | let (tx, rx) = tokio::sync::oneshot::channel(); |
| 97 | |
| 98 | self.cmd_tx |
| 99 | .send(DriverCommand::Unsubscribe(query, tx)) |
| 100 | .map_err(|_| Error::channel_send())?; |
| 101 | |
| 102 | rx.await |
| 103 | .map_err(|e| Error::client_internal(e.to_string()))? |
| 104 | } |
| 105 | |
| 106 | fn close(self) -> Result<(), Error> { |
| 107 | self.cmd_tx |