Hoogle Search

Within LTS Haskell 24.52 (ghc-9.10.3)

Note that Stackage only displays results for the latest LTS and Nightly snapshot. Learn more.

  1. boundThreads :: Bool -> Config -> Config

    streamly Streamly.Internal.Data.Fold.Prelude

    Spawn bound threads (i.e., spawn threads using forkOS instead of forkIO). The default value is False. Currently, this only takes effect only for concurrent folds.

  2. allThreadsDone :: forall m (t :: (Type -> Type) -> Type -> Type) a . MonadIO m => SVar t m a -> m Bool

    streamly Streamly.Internal.Data.SVar

    This is safe even if we are adding more threads concurrently because if a child thread is adding another thread then anyway workerThreads will not be empty.

  3. delThread :: forall m (t :: (Type -> Type) -> Type -> Type) a . MonadIO m => SVar t m a -> ThreadId -> m ()

    streamly Streamly.Internal.Data.SVar

    No documentation available.

  4. minThreadDelay :: NanoSecond64

    streamly Streamly.Internal.Data.SVar

    This is a magic number and it is overloaded, and used at several places to achieve batching:

    1. If we have to sleep to slowdown this is the minimum period that we accumulate before we sleep. Also, workers do not stop until this much sleep time is accumulated.
    2. Collected latencies are computed and transferred to measured latency after a minimum of this period.

  5. modifyThread :: forall m (t :: (Type -> Type) -> Type -> Type) a . MonadIO m => SVar t m a -> ThreadId -> m ()

    streamly Streamly.Internal.Data.SVar

    No documentation available.

  6. maxThreads :: forall t (m :: Type -> Type) a . IsStream t => Int -> t m a -> t m a

    streamly Streamly.Internal.Data.Stream.IsStream

    Specify the maximum number of threads that can be spawned concurrently for any concurrent combinator in a stream. A value of 0 resets the thread limit to default, a negative value means there is no limit. The default value is 1500. maxThreads does not affect ParallelT streams as they can use unbounded number of threads. When the actions in a stream are IO bound, having blocking IO calls, this option can be used to control the maximum number of in-flight IO requests. When the actions are CPU bound this option can be used to control the amount of CPU used by the stream. Since: 0.4.0 (Streamly)

  7. maxThreads :: forall t (m :: Type -> Type) a . IsStream t => Int -> t m a -> t m a

    streamly Streamly.Internal.Data.Stream.IsStream

    Specify the maximum number of threads that can be spawned concurrently for any concurrent combinator in a stream. A value of 0 resets the thread limit to default, a negative value means there is no limit. The default value is 1500. maxThreads does not affect ParallelT streams as they can use unbounded number of threads. When the actions in a stream are IO bound, having blocking IO calls, this option can be used to control the maximum number of in-flight IO requests. When the actions are CPU bound this option can be used to control the amount of CPU used by the stream. Since: 0.4.0 (Streamly)

  8. runReaderT :: (IsStream t, Monad m) => m s -> t (ReaderT s m) a -> t m a

    streamly Streamly.Internal.Data.Stream.IsStream

    Evaluate the inner monad of a stream as ReaderT.

  9. usingReaderT :: (Monad m, IsStream t) => m r -> (t (ReaderT r m) a -> t (ReaderT r m) a) -> t m a -> t m a

    streamly Streamly.Internal.Data.Stream.IsStream

    Run a stream transformation using a given environment. See also: map Internal

  10. class Monad m => MonadReader r (m :: Type -> Type) | m -> r

    streamly Streamly.Internal.Data.Stream.MkType

    See examples in Control.Monad.Reader. Note, the partially applied function type (->) r is a simple reader monad. See the instance declaration below.

Page 824 of many | Previous | Next