diff --git a/lib/multi_channel.ml b/lib/multi_channel.ml index 40a7d0d..0834fde 100644 --- a/lib/multi_channel.ml +++ b/lib/multi_channel.ml @@ -147,7 +147,7 @@ let recv_poll_with_dls mchan dls = Ws_deque.pop (Array.unsafe_get mchan.channels dls.id) with | Exit -> - match Foreign_queue.pop mchan.foreign_queue with + match Foreign_queue.pop_opt mchan.foreign_queue with | None -> recv_poll_loop mchan dls 0 | Some v -> v [@@inline]