@@ -377,13 +377,9 @@ enumSocket th len socket =
377 bs <- liftIO $ Sock.recv socket len
377 bs <- liftIO $ Sock.recv socket len
378 liftIO $ T.tickle th
378 liftIO $ T.tickle th
379 if S.null bs
379 if S.null bs
380− then E.throwError SocketTimeout
380+ then E.continue k
381− else go k bs
381+ else k (E.Chunks [bs]) >>== inner
382 inner step = E.returnI step
382 inner step = E.returnI step
384− | S.length bs == 0 = E.continue k
385− | otherwise = k (E.Chunks [bs]) >>== enumSocket th len socket
387------ The functions below are not warp-specific and could be split out into a
383------ The functions below are not warp-specific and could be split out into a
388--separate package.
384--separate package.