Complete SenderCollect case of runPipelinedPeer

Relying on tryReadTBQueue
IntersectMBO · Feb 11, 2019 · 27f2c87 · 27f2c87
1 parent c153eb7
commit 27f2c87
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/typed-protocols/src/Network/TypedProtocol/Driver.hs b/typed-protocols/src/Network/TypedProtocol/Driver.hs
@@ -173,11 +173,10 @@ runPipelinedPeerSender receiveQueue collectQueue Codec{encode} Channel{send} =
       go n (k c)
 
     go (Succ n) (SenderCollect (Just k') k) = do
-      fail "TODO: need tryReadTBQueue"
---      mc <- atomically (tryReadTBQueue collectQueue)
---      case mc of
---        Nothing -> go (Succ n) k'
---        Just c  -> go n (k c)
+      mc <- atomically (tryReadTBQueue collectQueue)
+      case mc of
+        Nothing -> go (Succ n) k'
+        Just c  -> go n (k c)
 
 
 runPipelinedPeerReceiverQueue