Safe Haskell	None
Language	Haskell2010

Bluefin.Capability.Await

Contents

Synopsis

type Await a = Consume a
eachAwait :: forall b (es :: Effects) r. (forall (e :: Effects). Await b e -> Eff (e :& es) r) -> Eff es b -> Eff es r
awaitYield :: forall a (es :: Effects) r. (forall (e :: Effects). Await a e -> Eff (e :& es) r) -> (forall (e :: Effects). Yield a e -> Eff (e :& es) r) -> Eff es r
await :: forall (e :: Effects) (es :: Effects) a. e <: es => Consume a e -> Eff es a
takeAwait :: forall (e1 :: Effects) (es :: Effects) (e2 :: Effects) a. (e1 <: es, e2 <: es) => Int -> Await a e1 -> Yield a e2 -> Eff es ()

Documentation

Await allows you to await values during the execution of a Bluefin operation. It provides similar functionality to await from Conduit or Pipes.

For information about prompt finalization/resource safety when using Bluefin Consumes, see Bluefin.Coroutine.

Capability

Capability to await values of type a

Arguments

:: forall b (es :: Effects) r. (forall (e :: Effects). Await b e -> Eff (e :& es) r)	Body
-> Eff es b	Value to send to each `await` in the body.
-> Eff es r

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

Arguments

:: forall a (es :: Effects) r. (forall (e :: Effects). Await a e -> Eff (e :& es) r)	Starts running first. Each `await` from the `Consume` ...
-> (forall (e :: Effects). Yield a e -> Eff (e :& es) r)	... receives the value `yield`ed from the `Yield`
-> Eff es r

awaitYield is connectRequests specialized to Await and Yield, which is the most common case.

await :: forall (e :: Effects) (es :: Effects) a. e <: es => Consume a e -> Eff es a #

Arguments

:: forall (e1 :: Effects) (es :: Effects) (e2 :: Effects) a. (e1 <: es, e2 <: es)
=> Int
-> Await a e1
-> Yield a e2
-> Eff es ()	͘

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