final class DeserializeCtx[Rep] extends ClientDeserializeCtx[Rep]
- Annotations
- @deprecated
- Deprecated
(Since version 2018-8-13) Use ClientDeserializeCtx.
- Alphabetic
- By Inheritance
- DeserializeCtx
- ClientDeserializeCtx
- Function1
- 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
- def andThen[A](g: (ReqRep) => A): (Array[Byte]) => A
- Definition Classes
- Function1
- Annotations
- @unspecialized()
- def apply(responseBytes: Array[Byte]): ReqRep
- Definition Classes
- ClientDeserializeCtx → Function1
- 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 compose[A](g: (A) => Array[Byte]): (A) => ReqRep
- Definition Classes
- Function1
- Annotations
- @unspecialized()
- def deserializationTime: Long
Gets how long, in nanoseconds, it took for the client to deserialize the response from Thrift format.
Gets how long, in nanoseconds, it took for the client to deserialize the response from Thrift format.
Negative values indicate that this was not recorded and as such, should be ignored.
- Definition Classes
- ClientDeserializeCtx
- def deserialize(responseBytes: Array[Byte]): Try[Rep]
Deserialize the given bytes.
Deserialize the given bytes.
Ensures that deserialization will only happen once for non fan-out responses regardless of future inputs. If different bytes are seen on future calls, this will still return the first deserialized result.
- Definition Classes
- ClientDeserializeCtx
- 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()
- val request: Any
- Definition Classes
- DeserializeCtx → ClientDeserializeCtx
- def rpcName: Option[String]
Gets the rpc method's name, if set.
Gets the rpc method's name, if set.
- Definition Classes
- ClientDeserializeCtx
- def rpcName(name: String): Unit
Sets the name of the the rpc method.
Sets the name of the the rpc method.
- Definition Classes
- ClientDeserializeCtx
- def serializationTime: Long
Gets how long, in nanoseconds, it took for the client to serialize the request into Thrift format.
Gets how long, in nanoseconds, it took for the client to serialize the request into Thrift format.
Negative values indicate that this was not recorded and as such, should be ignored.
- Definition Classes
- ClientDeserializeCtx
- def serializationTime(nanos: Long): Unit
Sets how long, in nanoseconds, it took for the client to serialize the request into Thrift format.
Sets how long, in nanoseconds, it took for the client to serialize the request into Thrift format.
- Definition Classes
- ClientDeserializeCtx
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- Function1 → 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()