Class AsyncDeserializer<T, TParsedSchema>

Inheritance

object

AsyncSerde<TParsedSchema>

AsyncDeserializer<T, TParsedSchema>

JsonDeserializer<T>

ProtobufDeserializer<T>

Implements

IAsyncDeserializer<T>

Inherited Members

AsyncSerde<TParsedSchema>.schemaRegistryClient

AsyncSerde<TParsedSchema>.ruleRegistry

AsyncSerde<TParsedSchema>.useLatestVersion

AsyncSerde<TParsedSchema>.latestCompatibilityStrict

AsyncSerde<TParsedSchema>.useLatestWithMetadata

AsyncSerde<TParsedSchema>.subjectNameStrategy

AsyncSerde<TParsedSchema>.serdeMutex

AsyncSerde<TParsedSchema>.GetSubjectName(string, bool, string)

AsyncSerde<TParsedSchema>.GetSchema(string, int, string)

AsyncSerde<TParsedSchema>.GetParsedSchema(Schema)

AsyncSerde<TParsedSchema>.ParseSchema(Schema)

AsyncSerde<TParsedSchema>.ResolveReferences(Schema)

AsyncSerde<TParsedSchema>.GetMigrations(string, Schema, Schema)

AsyncSerde<TParsedSchema>.GetReaderSchema(string, Schema)

AsyncSerde<TParsedSchema>.ExecuteMigrations(IList<Migration>, bool, string, string, Headers, object)

AsyncSerde<TParsedSchema>.ExecuteRules(bool, string, string, Headers, RuleMode, Schema, Schema, object, FieldTransformer)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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, RuleRegistry)

Declaration

protected AsyncDeserializer(ISchemaRegistryClient schemaRegistryClient, SerdeConfig config, RuleRegistry ruleRegistry = null)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient
SerdeConfig	config
RuleRegistry	ruleRegistry

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

IAsyncDeserializer<T>

Extension Methods

SyncOverAsyncDeserializerExtensionMethods.AsSyncOverAsync<T>(IAsyncDeserializer<T>)