Skip to content

Commit bb64316

Browse files
Expose bfs/fair unfoldEach, concatFor ops
1 parent 6691a41 commit bb64316

File tree

1 file changed

+15
-1
lines changed

1 file changed

+15
-1
lines changed

core/src/Streamly/Data/Stream.hs

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -566,7 +566,9 @@ module Streamly.Data.Stream
566566
-- transformed stream at the end we can have a flipped version called
567567
-- "crossMap" or "nestWith".
568568
, crossWith
569-
-- , cross
569+
, cross
570+
, fairCrossWith
571+
, fairCross
570572
-- , joinInner
571573
-- , CrossStream (..)
572574

@@ -580,6 +582,8 @@ module Streamly.Data.Stream
580582
-- >>> unwords = Stream.unfoldEachSepBySeq " " Unfold.fromList
581583
--
582584
, unfoldEach
585+
, bfsUnfoldEach
586+
, fairUnfoldEach
583587
, unfoldEachSepBySeq
584588
, unfoldEachEndBySeq
585589

@@ -608,6 +612,16 @@ module Streamly.Data.Stream
608612
, concatEffect
609613
, concatMap
610614
, concatMapM
615+
-- , bfsConcatMap
616+
, fairConcatMap
617+
618+
, concatFor
619+
-- , bfsConcatFor
620+
, fairConcatFor
621+
622+
, concatForM
623+
-- , bfsConcatForM
624+
, fairConcatForM
611625

612626
-- * Repeated Fold
613627
-- | Idioms and equivalents of Data.List APIs:

0 commit comments

Comments
 (0)