Conduit解析器被提前中斷

Question

我正在開發一個程序，我需要從USB連接解析數據並將其寫入循環緩衝區。

我一直遇到的問題是解析器沒有使用輸入。我是否需要使用另一個操作員將解析器管道連接到ByteString s流？

如果我刪除了兩個'過濾器'dropC和dropWhileC，解析器會消耗一些輸入，但會失敗，因爲前幾個數據塊是垃圾。不知何故（我從來沒有用過它）顯然我的心理模型是如何運作的。

我也想知道空字符串是否被conduitParser視爲EOF標記，就像attoparsec自己的parseWith一樣。

-- | 
sourcePort :: SerialPort -> Producer IO ByteString 
sourcePort port = repeatMC (recv port 16) 


-- | 
parseSerialStream :: (Vector v (Int, Int)) => RingBuffer v (Int, Int) -> SerialPort -> IO() -- ConduitM a c IO() 
parseSerialStream buffer port = sourcePort port 
          .| dropC 4 
          .| dropWhileC B.null 
          .| conduitParser (parseMeasurement <* endOfLine) 
          $$ mapM_C (\item -> print item >> RB.append (snd item) buffer) 

Answer 1

@danidiaz已經在評論認爲dropC解釋等人不要產生任何值，這就是爲什麼你必須使用monadic組合而不是管道（.|）。

對於任何人都會遇到這個問題，詳見this answer。

此代碼按預期工作：

parseSerialStream :: RingBuffer VU.Vector (Int, Int) -> SerialPort -> IO() -- ConduitM a c IO() 
parseSerialStream buffer port = sourcePort port 
          .| (dropC 4 
          >> dropWhileC B.null 
          >> conduitParser (parseMeasurement <* endOfLine)) 
          $$ mapM_C (\item -> RB.append (snd item) buffer) 

我喜歡管雖然是什麼樣子。呵呵......