Class BinaryMessageDeserializer<TModel>
Wraps the consumed bytes stream into an instance of TModel.
Inherited Members
Namespace: Silverback.Messaging.BinaryMessages
Assembly: Silverback.Integration.dll
Syntax
public sealed class BinaryMessageDeserializer<TModel> : IMessageDeserializer, IEquatable<BinaryMessageDeserializer<TModel>> where TModel : IBinaryMessage, new()
Type Parameters
| Name | Description |
|---|---|
| TModel | The type of the IBinaryMessage implementation. |
Constructors
BinaryMessageDeserializer()
Wraps the consumed bytes stream into an instance of TModel.
Declaration
public BinaryMessageDeserializer()
Properties
RequireHeaders
Gets a value indicating whether this serializer (with the current configuration) needs the headers support to work properly.
Declaration
public bool RequireHeaders { get; }
Property Value
| Type | Description |
|---|---|
| bool |
Methods
DeserializeAsync(Stream?, MessageHeaderCollection, ConsumerEndpoint)
Deserializes the byte array into a message object.
Declaration
public ValueTask<DeserializedMessage> DeserializeAsync(Stream? messageStream, MessageHeaderCollection headers, ConsumerEndpoint endpoint)
Parameters
| Type | Name | Description |
|---|---|---|
| Stream | messageStream | The Stream containing the message to be deserialized. |
| MessageHeaderCollection | headers | The message headers collection. |
| ConsumerEndpoint | endpoint | The endpoint. |
Returns
| Type | Description |
|---|---|
| ValueTask<DeserializedMessage> | A ValueTask<TResult> representing the asynchronous operation. The task result contains the
deserialized message (or |
Equals(BinaryMessageDeserializer<TModel>?)
Wraps the consumed bytes stream into an instance of TModel.
Declaration
public bool Equals(BinaryMessageDeserializer<TModel>? other)
Parameters
| Type | Name | Description |
|---|---|---|
| BinaryMessageDeserializer<TModel> | other |
Returns
| Type | Description |
|---|---|
| bool |
Equals(object?)
Wraps the consumed bytes stream into an instance of TModel.
Declaration
public override bool Equals(object? obj)
Parameters
| Type | Name | Description |
|---|---|---|
| object | obj |
Returns
| Type | Description |
|---|---|
| bool |
Overrides
GetCompatibleSerializer()
Gets a new IMessageSerializer compatible with this deserializer.
Declaration
public IMessageSerializer GetCompatibleSerializer()
Returns
| Type | Description |
|---|---|
| IMessageSerializer | A new instance of an IMessageSerializer compatible with this deserializer. |
GetHashCode()
Wraps the consumed bytes stream into an instance of TModel.
Declaration
public override int GetHashCode()
Returns
| Type | Description |
|---|---|
| int |