Skip to content

Commit

Permalink
Expose CrossStreamK, filter, and concatMap in StreamK
Browse files Browse the repository at this point in the history
  • Loading branch information
adithyaov committed Dec 19, 2024
1 parent 20f6b6b commit e693a4d
Showing 1 changed file with 9 additions and 2 deletions.
11 changes: 9 additions & 2 deletions core/src/Streamly/Data/StreamK.hs
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,11 @@ module Streamly.Data.StreamK
-- * Type
StreamK

-- * CrossStreamK
, CrossStreamK
, unCross
, mkCross

-- * Construction
-- ** Primitives
-- | Primitives to construct a stream from pure values or monadic actions.
Expand Down Expand Up @@ -126,6 +131,7 @@ module Streamly.Data.StreamK
, mapM
, dropWhile
, take
, filter

-- * Combining Two Streams
-- | Unlike the operations in "Streamly.Data.Stream", these operations can
Expand Down Expand Up @@ -163,7 +169,7 @@ module Streamly.Data.StreamK
-- >>> concatForFoldableWith f xs g = Prelude.foldr (f . g) StreamK.nil xs
--
, concatEffect
-- , concatMap
, concatMap
, concatMapWith
, mergeMapWith

Expand All @@ -184,6 +190,7 @@ module Streamly.Data.StreamK
where

import Streamly.Internal.Data.StreamK
import Prelude hiding (reverse, zipWith, mapM, dropWhile, take)
import Prelude hiding
(reverse, zipWith, mapM, dropWhile, take, filter, concatMap)

#include "DocTestDataStreamK.hs"

0 comments on commit e693a4d

Please sign in to comment.