(&mut self)
| 1890 | |
| 1891 | #[instrument(level = "debug")] |
| 1892 | async fn sync(&mut self) -> Result<State, io::Error> { |
| 1893 | // Close the current transaction if we are in an implicit transaction. |
| 1894 | if self.adapter_client.session().transaction().is_implicit() { |
| 1895 | self.commit_transaction().await?; |
| 1896 | } |
| 1897 | self.ready().await |
| 1898 | } |
| 1899 | |
| 1900 | #[instrument(level = "debug")] |
| 1901 | async fn ready(&mut self) -> Result<State, io::Error> { |
no test coverage detected