Function pgmq_core::util::fetch_one_message
source · pub async fn fetch_one_message<T: for<'de> Deserialize<'de>>(
query: &str,
connection: &Pool<Postgres>
) -> Result<Option<Message<T>>, PgmqError>pub async fn fetch_one_message<T: for<'de> Deserialize<'de>>(
query: &str,
connection: &Pool<Postgres>
) -> Result<Option<Message<T>>, PgmqError>