Packages

p

s_mach

concurrent

package concurrent

s_mach.concurrent is an open-source Scala library that provides asynchronous serial and parallel execution flow control primitives for working with asynchronous tasks. An asynchronous task consists of two or more calls to function(s) that return a future result *A ⇒ Future[B] instead of the result A ⇒ B.

Note: only difference between 2.11 and 2.12 version is Future.unit is removed since its now part of std lib

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. concurrent
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait AsyncParThrowable extends Throwable

    A trait for capturing all failures thrown during an asynchronous parallel task.

    A trait for capturing all failures thrown during an asynchronous parallel task. The first failure is immediately available and all others can be retrieved by waiting on a future.

  2. trait CancellableDelayedFuture [A] extends DelayedFuture[A] with CancellableFuture[A]

    A trait for a future that will be started after a delay and can be cancelled

  3. trait CancellableFuture [A] extends Future[A]

    A trait for a future that can be cancelled if it has not been started

  4. trait DeferredFuture [A] extends Future[A]

    A trait for a future whose execution does not begin until some condition occurs.

    A trait for a future whose execution does not begin until some condition occurs. DeferredFuture completes once the start condition occurs and the deferred future completes.

  5. trait DelayedFuture [A] extends DeferredFuture[A]

    A trait for a future that will be started after a delay

  6. trait PeriodicTask extends AnyRef

    A trait for a task that after the initial delay expires, is repeatedly started with a specified period in the background.

    A trait for a task that after the initial delay expires, is repeatedly started with a specified period in the background. This will continue until the task is cancelled or a failure occurs.

  7. implicit final class SMach_Concurrent_PimpEverything [A] extends AnyVal
  8. implicit final class SMach_Concurrent_PimpMyAsyncConfigBuilder extends AnyVal with SMach_Concurrent_AbstractPimpMyAsyncConfig
  9. implicit final class SMach_Concurrent_PimpMyFuture [A] extends AnyVal
  10. implicit final class SMach_Concurrent_PimpMyFutureFuture [A] extends AnyVal
  11. implicit final class SMach_Concurrent_PimpMyFutureType extends AnyVal
  12. implicit final class SMach_Concurrent_PimpMyTraversableFuture [A, M[+AA] <: Traversable[AA]] extends AnyVal
  13. implicit final class SMach_Concurrent_PimpMyTraversableFutureTraversable [A, M[+AA] <: Traversable[AA], N[+AA] <: TraversableOnce[AA]] extends AnyVal
  14. implicit final class SMach_Concurrent_PimpMyTraversableOnce [A, M[+AA] <: TraversableOnce[AA]] extends AnyVal
  15. implicit final class SMach_Concurrent_PimpMyTraversableOnceFuture [A, M[AA] <: TraversableOnce[AA]] extends AnyVal
  16. trait ScheduledExecutionContext extends AnyRef

    A trait for scheduling delayed or periodic tasks

Value Members

  1. val async: AsyncConfigBuilder

    The global base asynchronous config builder configured with one worker (serial) operation with all options disabled by default

  2. object AsyncParThrowable extends Serializable
  3. object DeferredFuture
  4. object PeriodicTask
  5. object ScheduledExecutionContext

Inherited from AnyRef

Inherited from Any

Ungrouped