Skip to content
Permalink
Browse files

Make runConnectedPeers and runConnectedPeersPipelined symmetric in Pe…

…erRole
  • Loading branch information...
coot committed May 15, 2019
1 parent cb16663 commit 481414885df0043b351a9f93a63a7fe0922a76c8
Showing with 4 additions and 4 deletions.
  1. +4 −4 typed-protocols/src/Network/TypedProtocol/Driver.hs
@@ -298,8 +298,8 @@ runConnectedPeers :: (MonadSTM m, MonadAsync m, MonadCatch m,
=> m (Channel m bytes, Channel m bytes)
-> Tracer m (TraceSendRecv ps)
-> Codec ps failure m bytes
-> Peer ps AsClient st m a
-> Peer ps AsServer st m b
-> Peer ps pr st m a
-> Peer ps (FlipAgency pr) st m b
-> m (a, b)
runConnectedPeers createChannels tr codec client server =
createChannels >>= \(clientChannel, serverChannel) ->
@@ -315,8 +315,8 @@ runConnectedPeersPipelined :: (MonadSTM m, MonadAsync m, MonadCatch m,
-> Tracer m (TraceSendRecv ps)
-> Codec ps failure m bytes
-> Natural
-> PeerPipelined ps AsClient st m a
-> Peer ps AsServer st m b
-> PeerPipelined ps pr st m a
-> Peer ps (FlipAgency pr) st m b
-> m (a, b)
runConnectedPeersPipelined createChannels tr codec maxOutstanding client server =
createChannels >>= \(clientChannel, serverChannel) ->

0 comments on commit 4814148

Please sign in to comment.
You can’t perform that action at this time.