case class ScheduledExecutionContextImpl(delegate: ScheduledExecutorService)(implicit executionContext: ExecutionContext) extends ScheduledExecutionContext with Product with Serializable
- Alphabetic
- By Inheritance
- ScheduledExecutionContextImpl
- Serializable
- Serializable
- Product
- Equals
- ScheduledExecutionContext
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new ScheduledExecutionContextImpl(delegate: ScheduledExecutorService)(implicit executionContext: ExecutionContext)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- val delegate: ScheduledExecutorService
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
reportFailure(cause: Throwable): Unit
Report a failure.
Report a failure. Used to report failures during periodic tasks
- Definition Classes
- ScheduledExecutionContextImpl → ScheduledExecutionContext
-
def
schedule[A](delay: FiniteDuration)(task: ⇒ A): DelayedFuture[A]
Create a DelayedFuture that executes the supplied function after the given delay
Create a DelayedFuture that executes the supplied function after the given delay
- delay
the time from now to delay execution
- returns
a DelayedFuture that can be used to extract result
- Definition Classes
- ScheduledExecutionContextImpl → ScheduledExecutionContext
- Exceptions thrown
java.util.concurrent.RejectedExecutionException
if the task cannot be scheduled for execution
-
def
scheduleAtFixedRate[U](initialDelay: FiniteDuration, period: FiniteDuration, paused: Boolean = false)(task: () ⇒ U): PeriodicTask
Creates a PeriodicTask that executes first after the given initial delay, and subsequently with the given period.
Creates a PeriodicTask that executes first after the given initial delay, and subsequently with the given period. PeriodicTask may stopped using the cancel method. If a failure occurs while processing the task, the task is automatically cancelled. If any execution of this task takes longer than its period, then subsequent executions may start late, but will not concurrently execute.
- initialDelay
the time to delay first execution
- period
the period between successive executions
- paused
TRUE to start the periodic task paused FALSE to start running
- task
the task to execute
- returns
a PeriodicTask
- Definition Classes
- ScheduledExecutionContextImpl → ScheduledExecutionContext
- Exceptions thrown
java.lang.IllegalArgumentException
if period less than or equal to zerojava.util.concurrent.RejectedExecutionException
if the task cannot be scheduled for execution
-
def
scheduleCancellable[A](delay: FiniteDuration, fallback: ⇒ A)(task: ⇒ A): CancellableDelayedFuture[A]
Create a DelayedFuture that executes the supplied function after the given delay
Create a DelayedFuture that executes the supplied function after the given delay
- delay
the time from now to delay execution
- fallback
the value to return if the future is cancelled
- returns
a DelayedFuture that can be used to extract result or cancel (only before it has been started)
- Definition Classes
- ScheduledExecutionContextImpl → ScheduledExecutionContext
- Exceptions thrown
java.util.concurrent.RejectedExecutionException
if the task cannot be scheduled for execution
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )