3f841aa · streamly · git.iko.soy

src/Streamly/Data/Fold/Prelude.hs+1−1

compare with master

unifiedsplit

@@ -20,7 +20,7 @@ module Streamly.Data.Fold.Prelude

20 -- ** Configuration

21 , Config

22 , maxBuffer

23− , bound

23+ , boundThreads

24 , inspect

25

26 -- ** Combinators

src/Streamly/Internal/Data/Fold/Concurrent.hs+1−1

@@ -53,7 +53,7 @@ module Streamly.Internal.Data.Fold.Concurrent

53 -- * Configuration

54 Config

55 , maxBuffer

56− , bound

56+ , boundThreads

57 , inspect

58

59 -- * Combinators

src/Streamly/Internal/Data/Fold/Concurrent/Channel.hs+1−1

@@ -14,7 +14,7 @@ module Streamly.Internal.Data.Fold.Concurrent.Channel

14 -- * Configuration

15 , Config

16 , maxBuffer

17− , bound

17+ , boundThreads

18 , inspect

19

20 -- * Fold operations

src/Streamly/Internal/Data/Stream/Channel/Types.hs+6−5

@@ -76,7 +76,7 @@ module Streamly.Internal.Data.Stream.Channel.Types

76 , stopWhen

77 , ordered

78 , interleaved

79− , bound

79+ , boundThreads

80

81 , rate

82 , avgRate

@@ -546,13 +546,14 @@ interleaved flag st = st { _interleaved = flag }

546getInterleaved :: Config -> Bool

547getInterleaved = _interleaved

548

549+-- TODO: Make it consistently take effect everywhere.

550+

549-- | Spawn bound threads (i.e., spawn threads using 'forkOS' instead of

551-- | Spawn bound threads (i.e., spawn threads using 'forkOS' instead of

550-- 'forkIO'). The default value is 'False'.

552-- 'forkIO'). The default value is 'False'.

551--

553--

552−-- Currently, this only takes effect for concurrent folds. TODO: Make it

554+-- Currently, this only takes effect only for concurrent folds.

553−-- consistently take effect everywhere.

554−bound :: Bool -> Config -> Config

555+boundThreads :: Bool -> Config -> Config

555−bound flag st = st { _bound = flag }

556+boundThreads flag st = st { _bound = flag }

556

557

557getBound :: Config -> Bool

558getBound :: Config -> Bool

558getBound = _bound

559getBound = _bound