package pattern
Type Members
- final class PipeableCompletionStage[T] extends AnyRef
- final class PipeableFuture[T] extends AnyRef
Value Members
- def after[T](duration: FiniteDuration, using: Scheduler)(value: => Future[T])(implicit ec: ExecutionContext): Future[T]
- def after[T](duration: FiniteDuration)(value: => Future[T])(implicit system: ClassicActorSystemProvider): Future[T]
- def afterCompletionStage[T](duration: FiniteDuration, using: Scheduler)(value: => CompletionStage[T])(implicit ec: ExecutionContext): CompletionStage[T]
- def afterCompletionStage[T](duration: FiniteDuration)(value: => CompletionStage[T])(implicit system: ClassicActorSystemProvider): CompletionStage[T]
- def ask(actorSelection: ActorSelection, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def ask(actorSelection: ActorSelection, message: Any)(implicit timeout: Timeout): Future[Any]
- implicit def ask(actorSelection: ActorSelection): AskableActorSelection
- def ask(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
- implicit def ask(actorRef: ActorRef): AskableActorRef
- def askWithStatus(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def askWithStatus(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
- def gracefulStop(target: ActorRef, timeout: FiniteDuration, stopMessage: Any): Future[Boolean]
- implicit def pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]
- implicit def pipeCompletionStage[T](future: CompletionStage[T])(implicit executionContext: ExecutionContext): PipeableCompletionStage[T]
- def retry[T](attempt: () => Future[T], attempts: Int, delayFunction: (Int) => Option[FiniteDuration])(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int, delay: FiniteDuration)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int)(implicit ec: ExecutionContext): Future[T]
Inherited from RetrySupport
Value Members
- def retry[T](attempt: () => Future[T], attempts: Int, delayFunction: (Int) => Option[FiniteDuration])(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int, delay: FiniteDuration)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int)(implicit ec: ExecutionContext): Future[T]
Inherited from FutureTimeoutSupport
Value Members
- def after[T](duration: FiniteDuration, using: Scheduler)(value: => Future[T])(implicit ec: ExecutionContext): Future[T]
- def after[T](duration: FiniteDuration)(value: => Future[T])(implicit system: ClassicActorSystemProvider): Future[T]
- def afterCompletionStage[T](duration: FiniteDuration, using: Scheduler)(value: => CompletionStage[T])(implicit ec: ExecutionContext): CompletionStage[T]
- def afterCompletionStage[T](duration: FiniteDuration)(value: => CompletionStage[T])(implicit system: ClassicActorSystemProvider): CompletionStage[T]
Inherited from GracefulStopSupport
Value Members
- def gracefulStop(target: ActorRef, timeout: FiniteDuration, stopMessage: Any): Future[Boolean]
Inherited from AskSupport
Value Members
- def ask(actorSelection: ActorSelection, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def ask(actorSelection: ActorSelection, message: Any)(implicit timeout: Timeout): Future[Any]
- implicit def ask(actorSelection: ActorSelection): AskableActorSelection
- def ask(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
- implicit def ask(actorRef: ActorRef): AskableActorRef
- def askWithStatus(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def askWithStatus(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
Inherited from PipeToSupport
Value Members
- implicit def pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]
- implicit def pipeCompletionStage[T](future: CompletionStage[T])(implicit executionContext: ExecutionContext): PipeableCompletionStage[T]
Ungrouped
- final class PipeableCompletionStage[T] extends AnyRef
- final class PipeableFuture[T] extends AnyRef
- def after[T](duration: FiniteDuration, using: Scheduler)(value: => Future[T])(implicit ec: ExecutionContext): Future[T]
- def after[T](duration: FiniteDuration)(value: => Future[T])(implicit system: ClassicActorSystemProvider): Future[T]
- def afterCompletionStage[T](duration: FiniteDuration, using: Scheduler)(value: => CompletionStage[T])(implicit ec: ExecutionContext): CompletionStage[T]
- def afterCompletionStage[T](duration: FiniteDuration)(value: => CompletionStage[T])(implicit system: ClassicActorSystemProvider): CompletionStage[T]
- def ask(actorSelection: ActorSelection, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def ask(actorSelection: ActorSelection, message: Any)(implicit timeout: Timeout): Future[Any]
- implicit def ask(actorSelection: ActorSelection): AskableActorSelection
- def ask(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
- implicit def ask(actorRef: ActorRef): AskableActorRef
- def askWithStatus(actorRef: ActorRef, message: Any, sender: ActorRef)(implicit timeout: Timeout): Future[Any]
- def askWithStatus(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
- def gracefulStop(target: ActorRef, timeout: FiniteDuration, stopMessage: Any): Future[Boolean]
- implicit def pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]
- implicit def pipeCompletionStage[T](future: CompletionStage[T])(implicit executionContext: ExecutionContext): PipeableCompletionStage[T]
- def retry[T](attempt: () => Future[T], attempts: Int, delayFunction: (Int) => Option[FiniteDuration])(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int, delay: FiniteDuration)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int, minBackoff: FiniteDuration, maxBackoff: FiniteDuration, randomFactor: Double)(implicit ec: ExecutionContext, scheduler: Scheduler): Future[T]
- def retry[T](attempt: () => Future[T], attempts: Int)(implicit ec: ExecutionContext): Future[T]