summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--dht/src/Network/QueryResponse.hs10
1 files changed, 5 insertions, 5 deletions
diff --git a/dht/src/Network/QueryResponse.hs b/dht/src/Network/QueryResponse.hs
index 8e32899f..1bfa995f 100644
--- a/dht/src/Network/QueryResponse.hs
+++ b/dht/src/Network/QueryResponse.hs
@@ -122,9 +122,9 @@ layerTransport parse encode tr =
122-- is used to share the same underlying socket, so be sure to fork a thread for 122-- is used to share the same underlying socket, so be sure to fork a thread for
123-- both returned 'Transport's to avoid hanging. 123-- both returned 'Transport's to avoid hanging.
124partitionTransportM :: ((b,a) -> IO (Either (x,xaddr) (b,a))) 124partitionTransportM :: ((b,a) -> IO (Either (x,xaddr) (b,a)))
125 -> ((x,xaddr) -> IO (Maybe (c,a))) 125 -> ((y,xaddr) -> IO (Maybe (c,a)))
126 -> TransportA err a b c 126 -> TransportA err a b c
127 -> IO (Transport err xaddr x, TransportA err a b c) 127 -> IO (TransportA err xaddr x y, TransportA err a b c)
128partitionTransportM parse encodex tr = do 128partitionTransportM parse encodex tr = do
129 tchan <- atomically newTChan 129 tchan <- atomically newTChan
130 let ytr = tr { awaitMessage = \kont -> fix $ \again -> do 130 let ytr = tr { awaitMessage = \kont -> fix $ \again -> do
@@ -151,9 +151,9 @@ partitionTransportM parse encodex tr = do
151-- is used to share the same underlying socket, so be sure to fork a thread for 151-- is used to share the same underlying socket, so be sure to fork a thread for
152-- both returned 'Transport's to avoid hanging. 152-- both returned 'Transport's to avoid hanging.
153partitionTransport :: ((b,a) -> Either (x,xaddr) (b,a)) 153partitionTransport :: ((b,a) -> Either (x,xaddr) (b,a))
154 -> ((x,xaddr) -> Maybe (b,a)) 154 -> ((y,xaddr) -> Maybe (c,a))
155 -> Transport err a b 155 -> TransportA err a b c
156 -> IO (Transport err xaddr x, Transport err a b) 156 -> IO (TransportA err xaddr x y, TransportA err a b c)
157partitionTransport parse encodex tr = 157partitionTransport parse encodex tr =
158 partitionTransportM (return . parse) (return . encodex) tr 158 partitionTransportM (return . parse) (return . encodex) tr
159 159