ConcurrentTestContextImpl

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. val _activeExecutionCount: AtomicInteger

   

5. val _delayError_ns: AtomicLong

   

6. def activeExecutionCount: Int

   
   returns

   the current number of active Runnables and scheduled tasks being processed

   Definition Classes

   ConcurrentTestContextImpl → ConcurrentTestContext

7. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. def delay(delay_ns: Long): Unit

   

   precisely delay for a period of time in nanoseconds.

   precisely delay for a period of time in nanoseconds. If the elapsed time differs from the requested the delay, the error in delay is accumulated in delayError_ns

   Definition Classes

   ConcurrentTestContextImpl → ConcurrentTestContext

10. def delayError_ns: Long

    
    returns

    the accumulated delay error

    Definition Classes

    ConcurrentTestContextImpl → ConcurrentTestContext

11. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

12. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

13. def execute(runnable: Runnable): Unit

    

    Definition Classes

    ConcurrentTestContextImpl → ExecutionContext

14. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

15. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

16. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

17. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

18. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

19. final def notify(): Unit

    

    Definition Classes

    AnyRef

20. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

21. def prepare(): ExecutionContext

    

    Definition Classes

    ExecutionContext

22. def reportFailure(cause: Throwable): Unit

    

    Report a failure.

    Report a failure. Used to report failures during periodic tasks

    Definition Classes

    ConcurrentTestContextImpl → ScheduledExecutionContext → ExecutionContext

23. implicit val sched: SerializationSchedule[String]

    
    returns

    the SerializationSchedule for the context

    Definition Classes

    ConcurrentTestContextImpl → ConcurrentTestContext

24. def schedule[A](delay: FiniteDuration)(f: ⇒ 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

    f

    the function to execute

    returns

    a DelayedFuture that can be used to extract result

    Definition Classes

    ConcurrentTestContextImpl → ScheduledExecutionContext

    Exceptions thrown

    java.util.concurrent.RejectedExecutionException if the task cannot be scheduled for execution

25. 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

    ConcurrentTestContextImpl → ScheduledExecutionContext

    Exceptions thrown

    java.lang.IllegalArgumentException if period less than or equal to zero

    java.util.concurrent.RejectedExecutionException if the task cannot be scheduled for execution

26. def scheduleCancellable[A](delay: FiniteDuration, fallback: ⇒ A)(f: ⇒ 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

    f

    the function to execute

    returns

    a DelayedFuture that can be used to extract result or cancel (only before it has been started)

    Definition Classes

    ConcurrentTestContextImpl → ScheduledExecutionContext

    Exceptions thrown

    java.util.concurrent.RejectedExecutionException if the task cannot be scheduled for execution

27. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

28. def toString(): String

    

    Definition Classes

    AnyRef → Any

29. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

30. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

31. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32. def waitForActiveExecutionCount(_activeRunnableCount: Int): Unit

    

    Sleep until the active execution count is equal to or less than the specified value

    Sleep until the active execution count is equal to or less than the specified value

    Definition Classes

    ConcurrentTestContext