composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-10-26 19:50:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

Re-export entire submodules from Streamly.Internal.Data.Fold (#2505)

Browse Source 
Co-authored-by: Harendra Kumar <harendra@composewell.com>
This commit is contained in:
Ranjeet Ranjan 2023-08-09 23:08:10 +05:30 committed by GitHub
parent fb87c88ac0
commit be2b3d1bdc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
22 changed files with 2635 additions and 2601 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
benchmark/Streamly/Benchmark/Data/Fold.hs
View File

@ -32,7 +32,6 @@ import Streamly.Internal.Data.MutArray (MutArray)
import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Data.Fold.Prelude as Fold
import qualified Streamly.Internal.Data.Fold.Container as FL
import qualified Streamly.Internal.Data.Unfold as Unfold
import qualified Streamly.Internal.Data.Pipe as Pipe
import qualified Streamly.Internal.Data.Stream as Stream

2
benchmark/Streamly/Benchmark/Data/ParserK.hs
View File

@ -19,7 +19,7 @@ import Control.DeepSeq (NFData(..))
import Control.Monad.IO.Class (MonadIO)
import Data.Foldable (asum)
import Streamly.Data.Array (Array, Unbox)
import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Internal.Data.Fold (Fold(..))
import Streamly.Data.StreamK (StreamK)
import Streamly.Internal.Data.Parser
(ParseError(..), Parser(..), Initial(..), Step(..))

2
benchmark/Streamly/Benchmark/Unicode/Stream.hs
View File

@ -40,7 +40,7 @@ import Streamly.Benchmark.Common.Handle
#ifdef INSPECTION
import Streamly.Internal.Data.Unbox (Unbox)
import Streamly.Internal.Data.Stream.StreamD (Step(..))
import qualified Streamly.Internal.Data.Fold.Type as Fold
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Tuple.Strict as Strict
import qualified Streamly.Internal.Data.Array.Type as Array

1
core/src/Streamly/Data/Fold.hs
View File

@ -255,7 +255,6 @@ import Prelude
span, splitAt, break, mapM, maybe)
import Streamly.Internal.Data.Fold
import Streamly.Internal.Data.Fold.Container
#include "DocTestDataFold.hs"

2585
core/src/Streamly/Internal/Data/Fold.hs
View File

File diff suppressed because it is too large Load Diff

2598
core/src/Streamly/Internal/Data/Fold/Combinators.hs Normal file
View File

File diff suppressed because it is too large Load Diff

3
core/src/Streamly/Internal/Data/Fold/Container.hs
View File

@ -103,7 +103,8 @@ import qualified Data.Set as Set
import qualified Streamly.Internal.Data.IsMap as IsMap
import Prelude hiding (Foldable(..))
import Streamly.Internal.Data.Fold
import Streamly.Internal.Data.Fold.Type
import Streamly.Internal.Data.Fold.Combinators
-- $setup
-- >>> :m

2
core/src/Streamly/Internal/Data/Refold/Type.hs
View File

@ -52,7 +52,7 @@ import Prelude hiding (Foldable(..), take, iterate)
-- $setup
-- >>> :m
-- >>> import qualified Streamly.Internal.Data.Refold.Type as Refold
-- >>> import qualified Streamly.Internal.Data.Fold.Type as Fold
-- >>> import qualified Streamly.Internal.Data.Fold as Fold
-- >>> import qualified Streamly.Internal.Data.Stream as Stream
-- All folds in the Fold module should be implemented using Refolds.

12
core/streamly-core.cabal
View File

@ -287,9 +287,7 @@ library
-- streamly-core-stream-types
, Streamly.Internal.Data.SVar.Type
, Streamly.Internal.Data.Stream.StreamK.Type
, Streamly.Internal.Data.Fold.Step
, Streamly.Internal.Data.Refold.Type
, Streamly.Internal.Data.Fold.Type
, Streamly.Internal.Data.Unfold.Type
, Streamly.Internal.Data.Producer.Type
, Streamly.Internal.Data.Producer
@ -324,7 +322,6 @@ library
, Streamly.Internal.Data.Builder
, Streamly.Internal.Data.Unfold
, Streamly.Internal.Data.Fold.Tee
, Streamly.Internal.Data.Fold
, Streamly.Internal.Data.Fold.Chunked
, Streamly.Internal.Data.Fold.Window
, Streamly.Internal.Data.Parser
@ -335,7 +332,7 @@ library
-- streamly-containers (non-base)
, Streamly.Internal.Data.Fold.Container
, Streamly.Internal.Data.Fold
, Streamly.Internal.Data.Stream.Chunked
-- streamly-core-data-arrays
@ -409,7 +406,12 @@ library
, Streamly.Unicode.Stream
, Streamly.Unicode.String
other-modules:
Streamly.Internal.Data.Stream.StreamD.Container
Streamly.Internal.Data.Fold.Step
, Streamly.Internal.Data.Fold.Type
, Streamly.Internal.Data.Fold.Combinators
, Streamly.Internal.Data.Fold.Container
, Streamly.Internal.Data.Stream.StreamD.Container
, Streamly.Internal.Data.Stream.StreamD.Eliminate
, Streamly.Internal.Data.Stream.StreamD.Exception
, Streamly.Internal.Data.Stream.StreamD.Generate

2
src/Streamly/Data/Fold/Prelude.hs
View File

@ -16,7 +16,7 @@ import Control.Monad.IO.Class (MonadIO)
import Data.HashMap.Strict (HashMap)
import Data.Hashable (Hashable)
import Streamly.Data.Fold
import Streamly.Internal.Data.Fold.Container (toContainerIO)
import Streamly.Internal.Data.Fold (toContainerIO)
import Streamly.Internal.Data.IsMap.HashMap ()
-- | Split the input stream based on a hashable component of the key field and

2
src/Streamly/Internal/Data/Fold/Async.hs
View File

@ -22,7 +22,7 @@ import Control.Exception (SomeException(..), catch, mask)
import Control.Monad (void)
import Control.Monad.IO.Class (MonadIO(..))
import Streamly.Data.Fold (many)
import Streamly.Internal.Data.Fold.Type (Fold(..), Step (..))
import Streamly.Internal.Data.Fold (Fold(..), Step (..))
import Streamly.Internal.Control.Concurrent (MonadAsync, withRunInIO)
import Streamly.Internal.Data.Tuple.Strict (Tuple3'(..))

4
src/Streamly/Internal/Data/Fold/SVar.hs
View File

@ -18,9 +18,9 @@ where
import Control.Monad (void)
import Control.Monad.IO.Class (MonadIO(liftIO))
import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Internal.Data.Fold (Fold(..))
import qualified Streamly.Internal.Data.Fold.Type as FL (Step(Done, Partial))
import qualified Streamly.Internal.Data.Fold as FL (Step(Done, Partial))
import Streamly.Internal.Data.SVar

2
src/Streamly/Internal/Data/SmallArray.hs
View File

@ -54,7 +54,7 @@ import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))
import Streamly.Internal.Data.Unfold.Type (Unfold(..))
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Fold.Type as FL
import qualified Streamly.Internal.Data.Fold as FL
(Fold (..), Step (Done, Partial))
import Streamly.Internal.Data.SmallArray.Type

2
src/Streamly/Internal/Data/Stream/IsStream/Common.hs
View File

@ -72,7 +72,7 @@ import Control.Monad.IO.Class (MonadIO(..))
import Foreign.Storable (Storable)
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Array.Type (Array)
import Streamly.Internal.Data.Fold.Type (Fold (..))
import Streamly.Internal.Data.Fold (Fold (..))
import Streamly.Internal.Data.Stream.IsStream.Combinators (maxYields)
import Streamly.Internal.Data.Stream.IsStream.Type
(IsStream(..), fromStreamD, toStreamD)

2
src/Streamly/Internal/Data/Stream/IsStream/Reduce.hs
View File

@ -160,7 +160,7 @@ import Data.Maybe (isNothing)
import Data.Proxy (Proxy(..))
import Foreign.Storable (Storable)
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Fold.Type (Fold (..))
import Streamly.Internal.Data.Fold (Fold (..))
import Streamly.Internal.Data.IsMap (IsMap(..))
import Streamly.Internal.Data.Refold.Type (Refold (..))
import Streamly.Internal.Data.Parser (Parser (..), ParseError)

3
src/Streamly/Internal/Data/Stream/IsStream/Top.hs
View File

@ -72,8 +72,7 @@ import qualified Data.Map.Strict as Map
-- import qualified Streamly.Internal.Data.Array.Generic as Array
-- (fromStream, length, read)
-- import qualified Streamly.Data.Array.Mut as MA
import qualified Streamly.Internal.Data.Fold as Fold (one, last)
import qualified Streamly.Internal.Data.Fold.Type as Fold
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Parser as Parser
(groupByRollingEither)
-- import qualified Streamly.Internal.Data.Stream.IsStream.Lift as Stream

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

@ -220,7 +220,7 @@ import Control.Monad.Trans.Class (MonadTrans(..))
import Data.Either (isLeft, isRight, fromLeft, fromRight)
import Data.Kind (Type)
import Data.Maybe (isJust, fromJust)
import Streamly.Internal.Data.Fold.Type (Fold (..))
import Streamly.Internal.Data.Fold (Fold (..))
import Streamly.Internal.Data.Pipe.Type (Pipe (..))
import Streamly.Internal.Data.Stream.IsStream.Combinators
( inspectMode, maxBuffer, maxThreads, rate, avgRate, minRate

2
src/Streamly/Internal/Data/Stream/IsStream/Type.hs
View File

@ -103,7 +103,7 @@ module Streamly.Internal.Data.Stream.IsStream.Type {-# DEPRECATED "Please use \"
where
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Fold.Type (Fold (..))
import Streamly.Internal.Data.Fold (Fold (..))
import Streamly.Internal.Data.Stream.Serial
(SerialT, Serial, WSerialT(..), WSerial)
import Streamly.Internal.Data.Stream.Async

2
src/Streamly/Internal/Data/Stream/SVar/Eliminate.hs
View File

@ -36,7 +36,7 @@ import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Control.ForkLifted (doFork)
import Streamly.Internal.Data.Atomics (atomicModifyIORefCAS_)
import Streamly.Internal.Data.Fold.SVar (write, writeLimited)
import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Internal.Data.Fold (Fold(..))
import Streamly.Internal.Data.Stream.Serial (SerialT)
import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)

2
src/Streamly/Internal/Data/Stream/Time.hs
View File

@ -60,7 +60,7 @@ import Data.Map (Map)
import Data.Maybe (isNothing)
import Data.Proxy (Proxy(..))
import Streamly.Data.Fold (Fold)
import Streamly.Internal.Data.Fold.Type (Fold (..))
import Streamly.Internal.Data.Fold (Fold (..))
import Streamly.Internal.Data.IsMap (IsMap(..))
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Time.Units

4
src/Streamly/Internal/Network/Inet/TCP.hs
View File

@ -107,7 +107,7 @@ import Prelude hiding (read)
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Control.ForkLifted (fork)
import Streamly.Internal.Data.Array.Type (Array(..), pinnedWriteNUnsafe)
import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Internal.Data.Fold (Fold(..))
import Streamly.Data.Stream (Stream)
import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))
import Streamly.Internal.Data.Unbox (Unbox)
@ -123,7 +123,7 @@ import qualified Streamly.Data.Fold as FL
import qualified Streamly.Data.Unfold as UF
import qualified Streamly.Internal.Data.Array.Type as A
import qualified Streamly.Internal.Data.Unfold as UF (first, bracketIO)
import qualified Streamly.Internal.Data.Fold.Type as FL (Step(..), reduce)
import qualified Streamly.Internal.Data.Fold as FL (Step(..), reduce)
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.Exception.Lifted as S
import qualified Streamly.Internal.Network.Socket as ISK

1
test/Streamly/Test/Data/Fold.hs
View File

@ -25,7 +25,6 @@ import qualified Data.Map
import qualified Prelude
import qualified Streamly.Internal.Data.MutArray as MArray
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Fold.Container as Fold
import qualified Streamly.Internal.Data.Stream as Stream
import Prelude hiding