Packages

class Counter extends AnyRef

An asynchronous counter that can be used to across the cluster to maintain a consistent count.

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

Instance Constructors

  1. new Counter(_asJava: AnyRef)

Value Members

  1. def addAndGet(value: Long, resultHandler: Handler[AsyncResult[Long]]): Unit

    Add the value to the counter atomically and return the new count * @param value the value to add

    Add the value to the counter atomically and return the new count * @param value the value to add

    resultHandler

    handler which will be passed the value

  2. def addAndGetFuture(value: Long): scala.concurrent.Future[Long]

    Like addAndGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  3. def asJava: AnyRef
  4. def compareAndSet(expected: Long, value: Long, resultHandler: Handler[AsyncResult[Boolean]]): Unit

    Set the counter to the specified value only if the current value is the expectec value.

    Set the counter to the specified value only if the current value is the expectec value. This happens atomically. * @param expected the expected value

    value

    the new value

    resultHandler

    the handler will be passed true on success

  5. def compareAndSetFuture(expected: Long, value: Long): scala.concurrent.Future[Boolean]

    Like compareAndSet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  6. def decrementAndGet(resultHandler: Handler[AsyncResult[Long]]): Unit

    Decrement the counter atomically and return the new count * @param resultHandler handler which will be passed the value

  7. def decrementAndGetFuture(): scala.concurrent.Future[Long]

    Like decrementAndGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  8. def get(resultHandler: Handler[AsyncResult[Long]]): Unit

    Get the current value of the counter * @param resultHandler handler which will be passed the value

  9. def getAndAdd(value: Long, resultHandler: Handler[AsyncResult[Long]]): Unit

    Add the value to the counter atomically and return the value before the add * @param value the value to add

    Add the value to the counter atomically and return the value before the add * @param value the value to add

    resultHandler

    handler which will be passed the value

  10. def getAndAddFuture(value: Long): scala.concurrent.Future[Long]

    Like getAndAdd but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  11. def getAndIncrement(resultHandler: Handler[AsyncResult[Long]]): Unit

    Increment the counter atomically and return the value before the increment.

    Increment the counter atomically and return the value before the increment. * @param resultHandler handler which will be passed the value

  12. def getAndIncrementFuture(): scala.concurrent.Future[Long]

    Like getAndIncrement but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  13. def getFuture(): scala.concurrent.Future[Long]

    Like get but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  14. def incrementAndGet(resultHandler: Handler[AsyncResult[Long]]): Unit

    Increment the counter atomically and return the new count * @param resultHandler handler which will be passed the value

  15. def incrementAndGetFuture(): scala.concurrent.Future[Long]

    Like incrementAndGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.