Package

s_mach

concurrent

Permalink

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

    Permalink

    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]

    Permalink

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

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

    Permalink

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

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

    Permalink

    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]

    Permalink

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

  6. trait PeriodicTask extends AnyRef

    Permalink

    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

    Permalink
  8. implicit final class SMach_Concurrent_PimpMyAsyncConfigBuilder extends AnyVal with SMach_Concurrent_AbstractPimpMyAsyncConfig

    Permalink
  9. implicit final class SMach_Concurrent_PimpMyFuture[A] extends AnyVal

    Permalink
  10. implicit final class SMach_Concurrent_PimpMyFutureFuture[A] extends AnyVal

    Permalink
  11. implicit final class SMach_Concurrent_PimpMyFutureType extends AnyVal

    Permalink
  12. implicit final class SMach_Concurrent_PimpMyTraversableFuture[A, M[+AA] <: Traversable[AA]] extends AnyVal

    Permalink
  13. implicit final class SMach_Concurrent_PimpMyTraversableFutureTraversable[A, M[+AA] <: Traversable[AA], N[+AA] <: TraversableOnce[AA]] extends AnyVal

    Permalink
  14. implicit final class SMach_Concurrent_PimpMyTraversableOnce[A, M[+AA] <: TraversableOnce[AA]] extends AnyVal

    Permalink
  15. implicit final class SMach_Concurrent_PimpMyTraversableOnceFuture[A, M[AA] <: TraversableOnce[AA]] extends AnyVal

    Permalink
  16. trait ScheduledExecutionContext extends AnyRef

    Permalink

    A trait for scheduling delayed or periodic tasks

Value Members

  1. object AsyncParThrowable extends Serializable

    Permalink
  2. object DeferredFuture

    Permalink
  3. object PeriodicTask

    Permalink
  4. object ScheduledExecutionContext

    Permalink
  5. val async: AsyncConfigBuilder

    Permalink

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

  6. package config

    Permalink
  7. package impl

    Permalink
  8. package util

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped