class SerialServerDispatcher[Req, Rep] extends GenSerialServerDispatcher[Req, Rep, Rep, Req]
Dispatch requests from transport one at a time, queueing concurrent requests.
Transport errors are considered fatal; the service will be released after any error.
- Alphabetic
- By Inheritance
- SerialServerDispatcher
- GenSerialServerDispatcher
- Closable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
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()
- def close(deadline: Time): Future[Unit]
- Definition Classes
- GenSerialServerDispatcher → Closable
- def close(after: Duration): Future[Unit]
- Definition Classes
- Closable
- final def close(): Future[Unit]
- Definition Classes
- Closable
- def dispatch(req: Req, eos: Promise[Unit]): Future[Rep]
Dispatches a request.
Dispatches a request. The first argument is the request. The second argument
eos
(end-of-stream promise) must be fulfilled when the request is complete.For non-streaming requests,
eos.setDone()
should be called immediately, since the entire request is present. For streaming requests,eos.setDone()
must be called at the end of stream (in HTTP, this is on receipt of last chunk). Refer to the implementation incom.twitter.finagle.http.codec.HttpServerDispatcher
.- Attributes
- protected
- Definition Classes
- SerialServerDispatcher → GenSerialServerDispatcher
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def handle(rep: Rep): Future[Unit]
- Attributes
- protected
- Definition Classes
- SerialServerDispatcher → GenSerialServerDispatcher
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def isClosing: Boolean
Exposed for testing
Exposed for testing
- Attributes
- protected[finagle.dispatch]
- Definition Classes
- GenSerialServerDispatcher
- 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()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()