pub fn sqlite_query_tokio_receiver_stream<T, F, C>(
mbt: &C,
query_override: &str,
row_mapper: F,
) -> UtilesResult<ReceiverStream<T>>where
F: Fn(&Row<'_>) -> RusqliteResult<T> + Send + Sync + 'static,
T: Send + 'static,
C: AsyncSqliteConn + Clone + 'static,