akka.remote.transport

Class ThrottlerTransportAdapter.Unthrottled$

java.lang.Object

akka.remote.transport.ThrottlerTransportAdapter.Unthrottled$

All Implemented Interfaces:

NoSerializationVerificationNeeded, ThrottlerTransportAdapter.ThrottleMode, java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

ThrottlerTransportAdapter

public static class ThrottlerTransportAdapter.Unthrottled$
extends java.lang.Object
implements ThrottlerTransportAdapter.ThrottleMode, scala.Product, scala.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static ThrottlerTransportAdapter.Unthrottled$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Unthrottled$()

Method Summary

Modifier and Type	Method and Description
ThrottlerTransportAdapter.Unthrottled$	getInstance() Java API: get the singleton instance
scala.concurrent.duration.FiniteDuration	timeToAvailable(long currentNanoTime, int tokens)
scala.Tuple2<ThrottlerTransportAdapter.ThrottleMode,java.lang.Object>	tryConsumeTokens(long nanoTimeOfSend, int tokens)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final ThrottlerTransportAdapter.Unthrottled$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Unthrottled$

public Unthrottled$()

Method Detail

tryConsumeTokens

public scala.Tuple2<ThrottlerTransportAdapter.ThrottleMode,java.lang.Object> tryConsumeTokens(long nanoTimeOfSend,
                                                                                              int tokens)

Specified by:

tryConsumeTokens in interface ThrottlerTransportAdapter.ThrottleMode

timeToAvailable

public scala.concurrent.duration.FiniteDuration timeToAvailable(long currentNanoTime,
                                                                int tokens)

Specified by:

timeToAvailable in interface ThrottlerTransportAdapter.ThrottleMode

getInstance

public ThrottlerTransportAdapter.Unthrottled$ getInstance()

Java API: get the singleton instance

Returns:

(undocumented)