diff options
| -rw-r--r-- | src/Network/Protocol.hs | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/Network/Protocol.hs b/src/Network/Protocol.hs index e286a67..0f099e0 100644 --- a/src/Network/Protocol.hs +++ b/src/Network/Protocol.hs @@ -267,6 +267,7 @@ passUpIncoming GlobalState {..} = do processIncoming :: GlobalState addr -> STM (IO ()) processIncoming gs@GlobalState {..} = do guard =<< isEmptyTMVar gNextUp + guard =<< canWriteFlow gControlFlow (addr, msg) <- readFlow gDataFlow mbconn <- findConnection gs addr |