diff options
-rw-r--r-- | dht/src/Network/QueryResponse.hs | 10 |
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. |
124 | partitionTransportM :: ((b,a) -> IO (Either (x,xaddr) (b,a))) | 124 | partitionTransportM :: ((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) |
128 | partitionTransportM parse encodex tr = do | 128 | partitionTransportM 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. |
153 | partitionTransport :: ((b,a) -> Either (x,xaddr) (b,a)) | 153 | partitionTransport :: ((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) |
157 | partitionTransport parse encodex tr = | 157 | partitionTransport parse encodex tr = |
158 | partitionTransportM (return . parse) (return . encodex) tr | 158 | partitionTransportM (return . parse) (return . encodex) tr |
159 | 159 | ||