Execute a closure with access to the session's connection
(
&self,
session_id: &Uuid,
f: F
)
| 2572 | |
| 2573 | // Execute a closure with access to the session's connection |
| 2574 | pub async fn with_session_connection<F, R>( |
| 2575 | &self, |
| 2576 | session_id: &Uuid, |
| 2577 | f: F |
| 2578 | ) -> Result<R, PgSqliteError> |
| 2579 | where |
| 2580 | F: FnOnce(&rusqlite::Connection) -> Result<R, rusqlite::Error> |
| 2581 | { |
| 2582 | self.connection_manager.execute_with_session(session_id, f) |
| 2583 | } |
| 2584 | |
| 2585 | pub async fn with_session_connection_mut<F, R>( |
| 2586 | &self, |
no test coverage detected