Packages

p

akka

pattern

package pattern

Linear Supertypes
RetrySupport, FutureTimeoutSupport, GracefulStopSupport, AskSupport, PipeToSupport, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. pattern
  2. RetrySupport
  3. FutureTimeoutSupport
  4. GracefulStopSupport
  5. AskSupport
  6. PipeToSupport
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final class PipeableCompletionStage[T] extends AnyRef
    Definition Classes
    PipeToSupport
  2. final class PipeableFuture[T] extends AnyRef
    Definition Classes
    PipeToSupport

Value Members

  1. def after[T](duration: FiniteDuration, using: Scheduler)(value: => Future[T])(implicit ec: ExecutionContext): Future[T]
    Definition Classes
    FutureTimeoutSupport
  2. def after[T](duration: FiniteDuration)(value: => Future[T])(implicit system: ClassicActorSystemProvider): Future[T]
    Definition Classes
    FutureTimeoutSupport
  3. def afterCompletionStage[T](duration: FiniteDuration, using: Scheduler)(value: => CompletionStage[T])(implicit ec: ExecutionContext): CompletionStage[T]
    Definition Classes
    FutureTimeoutSupport
  4. def afterCompletionStage[T](duration: FiniteDuration)(value: => CompletionStage[T])(implicit system: ClassicActorSystemProvider): CompletionStage[T]
    Definition Classes
    FutureTimeoutSupport
  5. def ask(actorSelection: ActorSelection, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
    Definition Classes
    AskSupport
  6. def ask(actorSelection: ActorSelection, message: Any)(implicit timeout: Timeout): Future[Any]
    Definition Classes
    AskSupport
  7. implicit def ask(actorSelection: ActorSelection): AskableActorSelection
    Definition Classes
    AskSupport
  8. def ask(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
    Definition Classes
    AskSupport
  9. def ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
    Definition Classes
    AskSupport
  10. implicit def ask(actorRef: ActorRef): AskableActorRef
    Definition Classes
    AskSupport
  11. def askWithStatus(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
    Definition Classes
    AskSupport
  12. def askWithStatus(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
    Definition Classes
    AskSupport
  13. def gracefulStop(target: ActorRef, timeout: FiniteDuration, stopMessage: Any): Future[Boolean]
    Definition Classes
    GracefulStopSupport
  14. implicit def pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]
    Definition Classes
    PipeToSupport
  15. implicit def pipeCompletionStage[T](future: CompletionStage[T])(implicit executionContext: ExecutionContext): PipeableCompletionStage[T]
    Definition Classes
    PipeToSupport
  16. def retry[T](attempt: () => Future[T], shouldRetry: (Throwable) => Boolean, attempts: Int, delayFunction: (Int) => Option[FiniteDuration])(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
    Definition Classes
    RetrySupport
  17. def retry[T](attempt: () => Future[T], attempts: Int, delayFunction: (Int) => Option[FiniteDuration])(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
    Definition Classes
    RetrySupport
  18. def retry[T](attempt: () => Future[T], attempts: Int, delay: FiniteDuration)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
    Definition Classes
    RetrySupport
  19. def retry[T](attempt: () => Future[T], shouldRetry: (Throwable) => Boolean, attempts: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
    Definition Classes
    RetrySupport
  20. def retry[T](attempt: () => Future[T], attempts: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
    Definition Classes
    RetrySupport
  21. def retry[T](attempt: () => Future[T], shouldRetry: (Throwable) => Boolean, attempts: Int)(implicit ec: ExecutionContext): Future[T]
    Definition Classes
    RetrySupport
  22. def retry[T](attempt: () => Future[T], attempts: Int)(implicit ec: ExecutionContext): Future[T]
    Definition Classes
    RetrySupport

Inherited from RetrySupport

Inherited from FutureTimeoutSupport

Inherited from GracefulStopSupport

Inherited from AskSupport

Inherited from PipeToSupport

Inherited from AnyRef

Inherited from Any

Ungrouped