- whileConnected Nothing _ (_,[],_) = (Ok "", Nothing, [], False)
- whileConnected md _ (msgs,send,sendStopped)
- = (Ok "", Just (msgs++map decode (maybeToList md),[],sendStopped), map encode send, False)
+ //We stop
+ whileConnected _ _ (_,_,True) = (Ok "", Nothing, [], True)
+
+ //No new data and nothing to send
+ whileConnected Nothing acc (_,[],_) = (Ok acc, Nothing, [], False)
+
+ //New data and possibly something to send
+ whileConnected (Just newdata) acc (msgs,send,sendStopped)
+ # (acc, nd) = process (acc +++ newdata)
+ | isEmpty nd && isEmpty send = (Ok acc, Nothing, [], False)
+ = (Ok acc, Just (msgs++map decode nd,[],sendStopped), map encode send, False)
+
+ process :: String -> (String, [String])
+ process s = case indexOf "\n" s of
+ -1 = (s, [])
+ i = appSnd (\ss->[s % (0,i):ss]) (process (s % (i, size s)))