永遠に再試行する列挙子を作成する方法

Question

私はJohn Millikinの列挙子パッケージを使用しています。ソケット自体を接続し、結果のハンドルを列挙しようとする点を除いて、Data.Enumerator.Binary.enumHandleにほぼ等しいものを作成しようとしています。難しさは、接続が信頼できないという事実から来ています。何かが間違っていたら、再接続して列挙を再開したいと思います。

私は通常Enumeratorが意味のあるMonadインスタンスであることを期待していますが、関数の型別名であるため、モナドの動作は入力ステップの読者に過ぎません。ここに。 catchErrorを使用して列挙子を繰り返しループしていたものを一緒に投げ込もうとしましたが、期待したことができず、何をしているのか分からなかったので、誰でも素敵な慣用的アプローチを提案できますか？この。明らかに私が省略した多くの詳細があるので、私は解決策の骨組みだけでうまくいく。

アイデア？

Answer 1

あなたはおそらくそれを自分で書く必要があります。私はどこにでも定義されているとは思わない。しかしそれほど難しいことではありません：

enumConnectAgain :: forall b m. MonadIO m => IO Handle -> Enumerator ByteString m b 
enumConnectAgain open step = 
    fix $ \again -> do 
     mh <- liftIO (Ex.try open) 
     case mh of 
      Left (ex :: SomeException) -> again 
      Right h     -> loop h step 

    where 
    loop :: Handle -> Step ByteString m b -> Iteratee ByteString m b 
    loop h step@(Continue k) = do 
     mstr <- liftIO (Ex.try $ B.hGetSome h 1024) 
     case mstr of 
      Left (ex :: SomeException) -> enumConnectAgain open step 
      Right str     -> k (Chunks [str]) >>== loop h 
    loop h step = returnI step 

これはうまくいくはずです。

Answer 2

若干高い視点からは、ソケット、特に信頼性が低い可能性のあるものでは、zeromqを十分に推奨できません。