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. chunkReaderWith :: forall (m :: Type -> Type) . MonadIO m => Unfold m (Int, Handle) (Array Word8)

    streamly-core Streamly.FileSystem.Handle

    Unfold the tuple (bufsize, handle) into a stream of Word8 arrays. Read requests to the IO device 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.

  2. chunkReader :: forall (m :: Type -> Type) . MonadIO m => Unfold m () (Array Word8)

    streamly-core Streamly.Internal.Console.Stdio

    Unfolds standard input into a stream of Word8 arrays.

  3. indexReader :: forall (m :: Type -> Type) a . (Monad m, Unbox a) => Stream m Int -> Unfold m (Array a) a

    streamly-core Streamly.Internal.Data.Array

    Given a stream of array indices, read the elements on those indices from the supplied Array. An exception is thrown if an index is out of bounds. This is the most general operation. We can implement other operations in terms of this: 

    read =
let u = lmap (arr -> (0, length arr - 1)) Unfold.enumerateFromTo
in Unfold.lmap f (indexReader arr)

readRev =
let i = length arr - 1
in Unfold.lmap f (indexReaderFromThenTo i (i - 1) 0)
    Pre-release

  4. indexReaderFromThenTo :: forall (m :: Type -> Type) a . Unfold m (Int, Int, Int, Array a) a

    streamly-core Streamly.Internal.Data.Array

    Unfolds (from, then, to, array) generating a finite stream whose first element is the array value from the index from and the successive elements are from the indices in increments of then up to to. Index enumeration can occur downwards or upwards depending on whether then comes before or after from. 

    getIndicesFromThenTo =
let f (from, next, to, arr) =
(Stream.enumerateFromThenTo from next to, arr)
in Unfold.lmap f getIndices
    Unimplemented

  5. indexReader :: forall (m :: Type -> Type) a . (MonadIO m, Unbox a) => Stream m Int -> Unfold m (MutArray a) a

    streamly-core Streamly.Internal.Data.MutArray

    Given an unfold that generates array indices, read the elements on those indices from the supplied MutArray. An error is thrown if an index is out of bounds. Pre-release

  6. indexReaderWith :: (Monad m, Unbox a) => (forall b . () => IO b -> m b) -> Stream m Int -> Unfold m (MutArray a) a

    streamly-core Streamly.Internal.Data.MutArray

    No documentation available.

  7. unread :: [b] -> Source a b -> Source a b

    streamly-core Streamly.Internal.Data.Producer

    Return some unused data back to the source. The data is prepended (or consed) to the source. Pre-release

  8. data ThreadAbort

    streamly-core Streamly.Internal.Data.SVar.Type

    No documentation available.

  9. ThreadAbort :: ThreadAbort

    streamly-core Streamly.Internal.Data.SVar.Type

    No documentation available.

  10. accountThread :: SVar (t :: (Type -> Type) -> Type -> Type) (m :: Type -> Type) a -> ThreadId -> m ()

    streamly-core Streamly.Internal.Data.SVar.Type

    No documentation available.

Page 729 of many | Previous | Next