trait StrictMessageSerializer[Message] extends MessageSerializer[Message, ByteString]
A strict message serializer, for messages that fit and are worked with strictly in memory.
Strict message serializers differ from streamed serializers, in that they work directly with ByteString, rather
than an Akka streams Source.
- Source
- MessageSerializer.scala
- Alphabetic
- By Inheritance
- StrictMessageSerializer
- MessageSerializer
- AnyRef
- Any
- by CollectionsHaveToParArray
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
deserializer(protocol: MessageProtocol): NegotiatedDeserializer[Message, ByteString]
Get a deserializer for an entity described by the given request or response protocol.
Get a deserializer for an entity described by the given request or response protocol.
- protocol
The protocol of the message request or response associated with the entity.
- returns
A deserializer for request/response messages.
- Definition Classes
- MessageSerializer
- Annotations
- @throws( ... )
- Exceptions thrown
UnsupportedMediaTypeIf the deserializer can't deserialize that protocol.
-
abstract
def
serializerForRequest: NegotiatedSerializer[Message, ByteString]
Get a serializer for a client request.
Get a serializer for a client request.
Since a client is the initiator of the request, it simply returns the default serializer for the entity.
- returns
A serializer for request messages.
- Definition Classes
- MessageSerializer
-
abstract
def
serializerForResponse(acceptedMessageProtocols: Seq[MessageProtocol]): NegotiatedSerializer[Message, ByteString]
Negotiate a serializer for the response, given the accepted message headers.
Negotiate a serializer for the response, given the accepted message headers.
- acceptedMessageProtocols
The accepted message headers is a list of message headers that will be accepted by the client. Any empty values in a message protocol, including the list itself, indicate that any format is acceptable.
- Definition Classes
- MessageSerializer
- Annotations
- @throws( ... )
- Exceptions thrown
NotAcceptableIf the serializer can't meet the requirements of any of the accept headers.
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to any2stringadd[StrictMessageSerializer[Message]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (StrictMessageSerializer[Message], B)
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to ArrowAssoc[StrictMessageSerializer[Message]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
acceptResponseProtocols: Seq[MessageProtocol]
The message headers that will be accepted for response serialization.
The message headers that will be accepted for response serialization.
- Definition Classes
- MessageSerializer
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
ensuring(cond: (StrictMessageSerializer[Message]) ⇒ Boolean, msg: ⇒ Any): StrictMessageSerializer[Message]
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to Ensuring[StrictMessageSerializer[Message]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (StrictMessageSerializer[Message]) ⇒ Boolean): StrictMessageSerializer[Message]
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to Ensuring[StrictMessageSerializer[Message]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): StrictMessageSerializer[Message]
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to Ensuring[StrictMessageSerializer[Message]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): StrictMessageSerializer[Message]
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to Ensuring[StrictMessageSerializer[Message]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to StringFormat[StrictMessageSerializer[Message]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isStreamed: Boolean
Whether this serializer is a streamed serializer or not.
Whether this serializer is a streamed serializer or not.
- returns
Whether this is a streamed serializer.
- Definition Classes
- MessageSerializer
-
def
isUsed: Boolean
Whether this serializer serializes values that are used or not.
Whether this serializer serializes values that are used or not.
If false, it means this serializer is for an empty request/response, eg, they use the akka.NotUsed type.
- returns
Whether the values this serializer serializes are used.
- Definition Classes
- MessageSerializer
-
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
toParArray: ParArray[T]
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to CollectionsHaveToParArray[StrictMessageSerializer[Message], T] performed by method CollectionsHaveToParArray in scala.collection.parallel. This conversion will take place only if an implicit value of type (StrictMessageSerializer[Message]) ⇒ GenTraversableOnce[T] is in scope.
- Definition Classes
- CollectionsHaveToParArray
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
→[B](y: B): (StrictMessageSerializer[Message], B)
- Implicit
- This member is added by an implicit conversion from StrictMessageSerializer[Message] to ArrowAssoc[StrictMessageSerializer[Message]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc