Hoogle Search

Within LTS Haskell 24.34 (ghc-9.10.3)

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

Exact lookup

1. module Bluefin.Consume

   No documentation available.

2. type Consume a = Coroutine () a

   bluefin	Bluefin.Consume

   No documentation available.

3. consumeEach :: forall b (es :: Effects) r . (forall (e :: Effects) . () => Consume b e -> Eff (e :& es) r) -> Eff es b -> Eff es r

   bluefin	Bluefin.Consume

   A version of forEach specialized to Consume. Every time the Consume is used to await a b, feed it the one created by the handler.

4. consumeStream :: forall a (es :: Effects) r . (forall (e :: Effects) . () => Consume a e -> Eff (e :& es) r) -> (forall (e :: Effects) . () => Stream a e -> Eff (e :& es) r) -> Eff es r

   bluefin	Bluefin.Consume

   No documentation available.

5. streamConsume :: forall a (es :: Effects) r . (forall (e :: Effects) . () => Stream a e -> Eff (e :& es) r) -> (forall (e :: Effects) . () => Consume a e -> Eff (e :& es) r) -> Eff es r

   bluefin	Bluefin.Consume

   Argument-flipped version of consumeStream

6. takeConsume :: forall (ea :: Effects) (es :: Effects) (eb :: Effects) a . (ea :> es, eb :> es) => Int -> Consume a ea -> Stream a eb -> Eff es ()

   bluefin	Bluefin.Consume

   runPureEff $ yieldToList $ yOut -> do
   consumeStream
   (c -> takeConsume 4 c yOut)
   (yIn -> inFoldable [1..10] yIn)
   ([1,2,3,4],())
   

7. type Consumer a = Pipe a Void

   bluefin	Bluefin.Pipes

   No documentation available.

8. consumeStream :: forall a (es :: Effects) r . (forall (e :: Effects) . () => Consume a e -> Eff (e :& es) r) -> (forall (e :: Effects) . () => Stream a e -> Eff (e :& es) r) -> Eff es r

   bluefin	Bluefin.Stream

   No documentation available.

9. streamConsume :: forall a (es :: Effects) r . (forall (e :: Effects) . () => Stream a e -> Eff (e :& es) r) -> (forall (e :: Effects) . () => Consume a e -> Eff (e :& es) r) -> Eff es r

   bluefin	Bluefin.Stream

   Argument-flipped version of consumeStream

10. takeConsume :: forall (ea :: Effects) (es :: Effects) (eb :: Effects) a . (ea :> es, eb :> es) => Int -> Consume a ea -> Stream a eb -> Eff es ()

    bluefin	Bluefin.Stream

    runPureEff $ yieldToList $ yOut -> do
    consumeStream
    (c -> takeConsume 4 c yOut)
    (yIn -> inFoldable [1..10] yIn)
    ([1,2,3,4],())
    

Page 234 of many | Previous | Next