Results for “Std.Concurrent.Cancel.Token”

Use module:Std.List, kind:fn, or is:exact. Put a Pudu type after ::.

• Std.Concurrent.Cancel.Token

  A request to stop, which work checks between steps.

  type · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.tokenStd.Concurrent.Cancel.Token

  A token that fires only when cancelled.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.cancel&Std.Concurrent.Cancel.Token -> Str -> Result[(), Std.Sync.SyncError]

  Ask the work holding this token, and every child of it, to stop.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.check&Std.Concurrent.Cancel.Token -> Result[(), Std.Concurrent.Cancel.Reason]

  Ok while the token has not fired, so work can stop with ?.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.child&Std.Concurrent.Cancel.Token -> Std.Concurrent.Cancel.Token

  A token that fires when its parent does.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.childExpiring&Std.Concurrent.Cancel.Token -> Int -> Std.Concurrent.Cancel.Token

  A child that also fires millis from now, or at its parent's deadline if

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.expiringInt -> Std.Concurrent.Cancel.Token

  A token that fires by itself millis from now.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.pause&Std.Concurrent.Cancel.Token -> Int -> Result[(), Std.Concurrent.Cancel.Reason]

  Sleep for millis, or until the token fires, whichever comes first.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.reason&Std.Concurrent.Cancel.Token -> Option[Std.Concurrent.Cancel.Reason]

  Why the token fired, or None while it has not. An ancestor's reason is

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.remaining&Std.Concurrent.Cancel.Token -> Option[Int]

  Milliseconds left before the deadline, never below zero, or None for a

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Cancel.stopped&Std.Concurrent.Cancel.Token -> Bool

  Whether the token has fired.

  fn · Std.Concurrent.Cancel
• Std.Concurrent.Future.firstSuccess&Std.Concurrent.Cancel.Token -> &Array[fn(Std.Concurrent.Cancel.Token) -> T] -> Result[T, Std.Concurrent.ConcurrentError]

  Run every action and answer the first to succeed; when none does, the

  fn · Std.Concurrent.Future
• Std.Concurrent.Future.race&Std.Concurrent.Cancel.Token -> &Array[fn(Std.Concurrent.Cancel.Token) -> T] -> Result[T, Std.Concurrent.ConcurrentError]

  Run every action and answer the first to settle, value or failure. The

  fn · Std.Concurrent.Future
• Std.Concurrent.Future.waitUntil&Std.Concurrent.Future.Future[T] -> &Std.Concurrent.Cancel.Token -> Result[Option[T], Std.Concurrent.ConcurrentError]

  Wait until the future settles or the token fires; None for the token.

  fn · Std.Concurrent.Future
• Std.Concurrent.Future.withinInt -> fn(Std.Concurrent.Cancel.Token) -> T -> Result[Option[T], Std.Concurrent.ConcurrentError]

  Run an action with a token that fires after millis; None when the

  fn · Std.Concurrent.Future
• Std.Concurrent.Retry.runCancellable&Std.Concurrent.Retry.Policy -> &Std.Concurrent.Cancel.Token -> fn(E) -> Bool -> fn(Int) -> Result[T, E] -> Result[T, Std.Concurrent.Retry.RetryError[E]]

  runWhen, stopping when the token fires: before each attempt and during

  fn · Std.Concurrent.Retry
• Std.Concurrent.Scope.all&Std.Concurrent.Cancel.Token -> &Array[fn(Std.Concurrent.Cancel.Token) -> Result[T, E]] -> Result[Array[T], Std.Concurrent.Scope.ScopeError[E]]

  Run every action on its own thread with one child token of parent, and

  fn · Std.Concurrent.Scope