pub fn new(
        descriptors: DecodedDescriptors,
        schema_registry: Option<ccsr::ClientConfig>,
    ) -> Result<Self, anyhow::Error> {
        Ok(Decoder {
            descriptors,
            packer: Default::default(),
            ccsr_client: schema_registry.map(|sr| sr.build()).transpose()?,
            validated_schema_id: Default::default(),
        })
    }
/// Constructs a decoder for a particular Protobuf message.
Constructs a decoder for a particular Protobuf message.
Constructs a decoder for a particular Protobuf message .
pub fn new(
        descriptors: DecodedDescriptors,
        schema_registry: Option<ccsr::ClientConfig>,
    ) -> Result<Self, anyhow::Error> {
        Ok(Decoder {
            descriptors,
            packer: Default::default(),
            ccsr_client: schema_registry.map(|sr| sr.build()).transpose()?,
            validated_schema_id: Default::default(),
        })
    }
pub fn new ( descriptors : DecodedDescriptors , schema_registry : Option < ccsr :: ClientConfig > , ) -> Result < Self , anyhow :: Error > { Ok ( Decoder { descriptors , packer : Default :: default ( ) , ccsr_client : schema_registry . map ( | sr | sr . build ( ) ) . transpose ( ) ? , validated_schema_id : Default :: default ( ) , } ) }
Constructs a decoder for a particular Protobuf message.
Constructs a decoder for a particular Protobuf message .
descriptors
DecodedDescriptors
schema_registry
Option<ccsr::ClientConfig>
descriptors
DecodedDescriptors
schema_registry
Option<ccsr::ClientConfig>