final class PipeliningClientPushSession[In, Out] extends PushSession[In, Out]
A Pipelined PushSession.
This assumes servers will respect normal pipelining semantics, and that replies will be sent in the same order as requests were sent.
Because many requests might be sharing the same push channel,
Futures returned by PipeliningClientPushSession#apply
are masked, and will only propagate the interrupt if the Future doesn't
return after a configurable amount of time after the interruption.
This ensures that interrupting a Future in one request won't change the
result of another request unless the connection is stuck, and does not
look like it will make progress. Use stallTimeout
to configure this timeout.
- Self Type
- PipeliningClientPushSession[In, Out]
- Alphabetic
- By Inheritance
- PipeliningClientPushSession
- PushSession
- Closable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PipeliningClientPushSession(handle: PushChannelHandle[In, Out], stallTimeout: Duration, timer: Timer)
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
- PipeliningClientPushSession → Closable
- def close(after: Duration): Future[Unit]
- Definition Classes
- Closable
- final def close(): Future[Unit]
- Definition Classes
- Closable
- 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 hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- 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()
- def receive(message: In): Unit
Receive a message, most commonly from the socket.
Receive a message, most commonly from the socket. Received messages are considered owned by the PushSession meaning the session is responsible for cleaning up any associated resources.
- Definition Classes
- PipeliningClientPushSession → PushSession
- def status: Status
The current availability Status of this PushSession.
The current availability Status of this PushSession.
- Definition Classes
- PipeliningClientPushSession → PushSession
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toService: Service[Out, In]
- 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()