Removed obsolete partitionAndForkTransport hack.

1 files changed, 1 insertions, 31 deletions

diff --git a/dht/src/Network/QueryResponse.hs b/dht/src/Network/QueryResponse.hs
index 1bfa995f..89723da2 100644
--- a/dht/src/Network/QueryResponse.hs
+++ b/dht/src/Network/QueryResponse.hs
@@ -52,7 +52,7 @@ import Data.TableMethods
 -- | An inbound packet or condition raised while monitoring a connection.
 data Arrival err addr x
     = Terminated       -- ^ Virtual message that signals EOF.
-    | ParseError !err  -- ^ A badly-formed message was recieved.
+    | ParseError !err  -- ^ A badly-formed message was received.
     | Arrival { arrivedFrom :: !addr , arrivedMsg  :: !x } -- ^ Inbound message.
 
 -- | Three methods are required to implement a datagram based query\/response protocol.
@@ -157,36 +157,6 @@ partitionTransport :: ((b,a) -> Either (x,xaddr) (b,a))
 partitionTransport parse encodex tr =
     partitionTransportM (return . parse) (return . encodex) tr
 
-
-partitionAndForkTransport ::
-                      (dst -> msg -> IO ())
-                      -> ((b,a) -> IO (Either (x,xaddr) (b,a)))
-                      -> ((x,xaddr) -> IO (Maybe (Either (msg,dst) (b,a))))
-                      -> Transport err a b
-                      -> IO (Transport err xaddr x, Transport err a b)
-partitionAndForkTransport forkedSend parse encodex tr = do
-    tchan <- atomically newTChan
-    let xtr = tr { awaitMessage = \kont -> fix $ \again -> do
-                    awaitMessage tr $ \case
-                        Arrival a b -> parse (b,a) >>= \case
-                            Left (x,xaddr) -> kont $ Arrival xaddr x
-                            Right (b,a)    -> atomically (writeTChan tchan (Arrival a b)) >> join (atomically again)
-                        ParseError e     -> kont $ ParseError e
-                        Terminated       -> atomically (writeTChan tchan Terminated) >> kont Terminated
-                 , sendMessage = \addr' msg' -> do
-                    msg_addr <- encodex (msg',addr')
-                    case msg_addr of
-                        Just (Right (b,a))    -> sendMessage tr a b
-                        Just (Left (msg,dst)) -> forkedSend dst msg
-                        Nothing               -> return ()
-                 }
-        ytr = Transport
-                { awaitMessage   = \kont -> readTChan tchan >>= pure . kont
-                , sendMessage    = sendMessage tr
-                , setActive      = \_ -> return ()
-                }
-    return (xtr, ytr)
-
 -- |
 --      * f add x --> Nothing, consume x
 --                --> Just id, leave x to a different handler