package
pattern
Type Members
-
final
class
PipeableFuture[T] extends AnyRef
Value Members
-
def
after[T](duration: FiniteDuration, using: Scheduler)(value: ⇒ Future[T])(implicit ec: ExecutionContext): Future[T]
-
def
ask(actorSelection: ActorSelection, message: Any)(implicit timeout: Timeout): Future[Any]
-
implicit
def
ask(actorSelection: ActorSelection): AskableActorSelection
-
def
ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
-
implicit
def
ask(actorRef: ActorRef): AskableActorRef
-
def
gracefulStop(target: ActorRef, timeout: FiniteDuration, stopMessage: Any): Future[Boolean]
-
implicit
def
pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]
Inherited from FutureTimeoutSupport
Value Members
-
def
after[T](duration: FiniteDuration, using: Scheduler)(value: ⇒ Future[T])(implicit ec: ExecutionContext): Future[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)(implicit timeout: Timeout): Future[Any]
-
implicit
def
ask(actorSelection: ActorSelection): AskableActorSelection
-
def
ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
-
implicit
def
ask(actorRef: ActorRef): AskableActorRef
Inherited from PipeToSupport
Value Members
-
implicit
def
pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]
Ungrouped
-
final
class
PipeableFuture[T] extends AnyRef
-
def
after[T](duration: FiniteDuration, using: Scheduler)(value: ⇒ Future[T])(implicit ec: ExecutionContext): Future[T]
-
def
ask(actorSelection: ActorSelection, message: Any)(implicit timeout: Timeout): Future[Any]
-
implicit
def
ask(actorSelection: ActorSelection): AskableActorSelection
-
def
ask(actorRef: ActorRef, message: Any)(implicit timeout: Timeout): Future[Any]
-
implicit
def
ask(actorRef: ActorRef): AskableActorRef
-
def
gracefulStop(target: ActorRef, timeout: FiniteDuration, stopMessage: Any): Future[Boolean]
-
implicit
def
pipe[T](future: Future[T])(implicit executionContext: ExecutionContext): PipeableFuture[T]