@@ -183,10 +183,10 @@ readArraysUpto :: (IsStream t, MonadIO m)
183readArraysUpto size h = go
183readArraysUpto size h = go
185 -- XXX use cons/nil instead
185 -- XXX use cons/nil instead
186− go = mkStream $ \_ yld sng _ -> do
186+ go = mkStream $ \_ yld _ stp -> do
187 arr <- liftIO $ readArrayUpto size h
187 arr <- liftIO $ readArrayUpto size h
188− if A.length arr < size
188+ if A.length arr == 0
189− then sng arr
189+ then stp
190 else yld arr go
190 else yld arr go
192-- XXX read 'Array a' instead of Word8
192-- XXX read 'Array a' instead of Word8