We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 72e10c3 commit 7e90612Copy full SHA for 7e90612
src/Simplex/Messaging/Server/MsgStore/Types.hs
@@ -93,6 +93,7 @@ class (Monad (StoreMonad s), QueueStoreClass (StoreQueue s) (QueueStore s)) => M
93
tryPeekMsg :: s -> StoreQueue s -> ExceptT ErrorType IO (Maybe Message)
94
tryPeekMsg st q = snd <$$> withPeekMsgQueue st q "tryPeekMsg" pure
95
{-# INLINE tryPeekMsg #-}
96
+
97
tryPeekMsgs :: s -> [StoreQueue s] -> ExceptT ErrorType IO (Map RecipientId Message)
98
tryPeekMsgs st qs = M.fromList . catMaybes <$> mapM (\q -> (recipientId q,) <$$> tryPeekMsg st q) qs
99
0 commit comments