Class AsyncDeserializer<T, TParsedSchema>

Inheritance
object
AsyncSerde<TParsedSchema>
AsyncDeserializer<T, TParsedSchema>
JsonDeserializer<T>
ProtobufDeserializer<T>
Implements
Inherited Members
Namespace: Confluent.SchemaRegistry
Assembly: Confluent.SchemaRegistry.dll
Syntax
public abstract class AsyncDeserializer<T, TParsedSchema> : AsyncSerde<TParsedSchema>, IAsyncDeserializer<T>
Type Parameters
Name Description
T
TParsedSchema

Constructors

AsyncDeserializer(ISchemaRegistryClient, SerdeConfig, IList<IRuleExecutor>)

Declaration
protected AsyncDeserializer(ISchemaRegistryClient schemaRegistryClient, SerdeConfig config, IList<IRuleExecutor> ruleExecutors = null)
Parameters
Type Name Description
ISchemaRegistryClient schemaRegistryClient
SerdeConfig config
IList<IRuleExecutor> ruleExecutors

Fields

headerSize

Declaration
protected readonly int headerSize
Field Value
Type Description
int

Methods

DeserializeAsync(ReadOnlyMemory<byte>, bool, SerializationContext)

Deserialize a message key or value.

Declaration
public abstract Task<T> DeserializeAsync(ReadOnlyMemory<byte> data, bool isNull, SerializationContext context)
Parameters
Type Name Description
ReadOnlyMemory<byte> data

The raw byte data to deserialize.
bool isNull

True if this is a null value.
SerializationContext context

Context relevant to the deserialize operation.
Returns
Type Description
Task<T>

A Task that completes with the deserialized value.

Implements

Extension Methods