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.
accountThread :: Channel (m :: Type -> Type) a -> ThreadId -> m ()streamly Streamly.Internal.Data.Stream.Prelude No documentation available.
maxThreads :: Int -> Config -> Configstreamly Streamly.Internal.Data.Stream.Prelude Specify the maximum number of threads that can be spawned by the channel. A value of 0 resets the thread limit to default, a negative value means there is no limit. The default value is 1500. 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.
workerThreads :: Channel (m :: Type -> Type) a -> IORef (Set ThreadId)streamly Streamly.Internal.Data.Stream.Prelude No documentation available.
chunkReader :: forall (m :: Type -> Type) . MonadIO m => Unfold m Socket (Array Word8)streamly Streamly.Internal.Network.Socket Unfolds a socket into a stream of Word8 arrays. Requests to the socket are performed using a buffer of size defaultChunkSize. The size of arrays in the resulting stream are therefore less than or equal to defaultChunkSize.
chunkReaderWith :: forall (m :: Type -> Type) . MonadIO m => Unfold m (Int, Socket) (Array Word8)streamly Streamly.Internal.Network.Socket Unfold the tuple (bufsize, socket) into a stream of Word8 arrays. Read requests to the socket are performed using a buffer of size bufsize. The size of an array in the resulting stream is always less than or equal to bufsize.
chunkReader :: forall (m :: Type -> Type) . MonadIO m => Unfold m Socket (Array Word8)streamly Streamly.Network.Socket Unfolds a socket into a stream of Word8 arrays. Requests to the socket are performed using a buffer of size defaultChunkSize. The size of arrays in the resulting stream are therefore less than or equal to defaultChunkSize.
chunkReaderWith :: forall (m :: Type -> Type) . MonadIO m => Unfold m (Int, Socket) (Array Word8)streamly Streamly.Network.Socket Unfold the tuple (bufsize, socket) into a stream of Word8 arrays. Read requests to the socket are performed using a buffer of size bufsize. The size of an array in the resulting stream is always less than or equal to bufsize.
maxThreads :: forall t (m :: Type -> Type) a . IsStream t => Int -> t m a -> t m astreamly Streamly.Prelude 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)
runReaderT :: (IsStream t, Monad m) => m s -> t (ReaderT s m) a -> t m astreamly Streamly.Prelude Evaluate the inner monad of a stream as ReaderT.
chunkReader :: forall (m :: Type -> Type) . Monad m => Unfold m ByteString (Array Word8)streamly-bytestring Streamly.External.ByteString.Lazy Unfold a lazy ByteString to a stream of Array Words.