handle package:streamly

handle :: (IsStream t, MonadCatch m, Exception e) => (e -> t m a) -> t m a -> t m a
streamly Streamly.Internal.Data.Stream.IsStream Streamly.Prelude
When evaluating a stream if an exception occurs, stream evaluation aborts and the specified exception handler is run with the exception as argument. Inhibits stream fusion
handleChildException :: IORef ([ChildEvent a], Int) -> MVar () -> SomeException -> IO ()
streamly Streamly.Internal.Data.Channel
handleChildException :: SVar t m a -> SomeException -> IO ()
streamly Streamly.Internal.Data.SVar
handleFoldException :: SVar t m a -> SomeException -> IO ()
streamly Streamly.Internal.Data.SVar
fromHandle :: (IsStream t, MonadIO m) => Handle -> t m String
streamly Streamly.Internal.Data.Stream.IsStream Streamly.Prelude
Read lines from an IO Handle into a stream of Strings.
ghandle :: (IsStream t, MonadCatch m, Exception e) => (e -> t m a -> t m a) -> t m a -> t m a
streamly Streamly.Internal.Data.Stream.IsStream
Like handle but the exception handler is also provided with the stream that generated the exception as input. The exception handler can thus re-evaluate the stream to retry the action that failed. The exception handler can again call ghandle on it to retry the action multiple times. This is highly experimental. In a stream of actions we can map the stream with a retry combinator to retry each action on failure. Inhibits stream fusion Pre-release
toHandle :: MonadIO m => Handle -> SerialT m String -> m ()
streamly Streamly.Internal.Data.Stream.IsStream Streamly.Prelude
toHandle h = D.mapM_ $ hPutStrLn h
Write a stream of Strings to an IO Handle.