FS.Concurrent.Util

Definitions

awaitRes : Deferred World (Result es a) -> Async e es a

  Awaits the completion of a `Deferred`, wrapping the
  result with the potential of failure.

Totality: total
Visibility: export

putErr : Deferred World (Result es ()) -> Outcome es () -> Async e [] ()

  Finalizes a deferred in case of an `Error` outcome.

Totality: total
Visibility: export

parrunCase : Deferred World a -> (Outcome fs () -> Async e [] ()) -> EmptyStream (Async e) fs -> Async e es (Fiber [] ())

  Concurrently runs the given stream until it either terminates or
  is interrupted by `check`.
  
  This is a low-level utility used to implement the combinators in this
  module. It is exported, because it might be useful when
  implementing other combinators,

Totality: total
Visibility: export

parrun : Deferred World a -> Async e [] () -> EmptyStream (Async e) fs -> Async e es (Fiber [] ())

  Concurrently runs the given stream until it either terminates or
  is interrupted by `check`.
  
  This is a low-level utility used to implement the combinators in this
  module. It is exported, because it might be useful when
  implementing other combinators,

Totality: total
Visibility: export