abstract class AsyncForwardingListener[ReqT] extends Listener[ReqT]
This listener buffers all messages until setNextListener is called,
at which point all buffered messages are sent to the given listener.
From then on, all future messages are sent directly to the given listener.
The target listener is usually created through Contexts.interceptCall or ServerCallHandler.startCall.
- Annotations
- @SuppressWarnings()
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AsyncForwardingListener
- Listener
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new AsyncForwardingListener()
Type Members
- type Listener = io.grpc.ServerCall.Listener[ReqT]
- Attributes
- protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def onCancel(): Unit
- Definition Classes
- AsyncForwardingListener → Listener
- def onComplete(): Unit
- Definition Classes
- AsyncForwardingListener → Listener
- def onHalfClose(): Unit
- Definition Classes
- AsyncForwardingListener → Listener
- def onMessage(message: ReqT): Unit
- Definition Classes
- AsyncForwardingListener → Listener
- def onReady(): Unit
- Definition Classes
- AsyncForwardingListener → Listener
- def setNextListener(listener: Listener): Unit
- Attributes
- protected
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])