composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-09-11 11:37:22 +03:00
Code Issues Packages Projects Releases Wiki Activity

Add a "both" utility function for either streams.

Browse Source
This commit is contained in:
Harendra Kumar 2021-07-29 01:27:07 +05:30
parent 064ac664c5
commit 2f5925b421
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Streamly/Internal/Data/Stream/IsStream/Transform.hs
View File

@ -164,6 +164,7 @@ module Streamly.Internal.Data.Stream.IsStream.Transform
-- Move these to Streamly.Data.Either.Stream?
, lefts
, rights
, both
-- * Concurrent Evaluation
-- ** Concurrent Pipelines
@ -1509,6 +1510,15 @@ lefts = fmap (fromLeft undefined) . filter isLeft
rights :: (IsStream t, Monad m, Functor (t m)) => t m (Either a b) -> t m b
rights = fmap (fromRight undefined) . filter isRight
-- | Remove the either wrapper and flatten both lefts and as well as rights in
-- the output stream.
--
-- /Pre-release/
--
{-# INLINE both #-}
both :: Functor (t m) => t m (Either a a) -> t m a
both = fmap (either id id)
------------------------------------------------------------------------------
-- Concurrent Application
------------------------------------------------------------------------------