lib/avromatic/messaging.rb in avromatic-0.15.1 vs lib/avromatic/messaging.rb in avromatic-0.17.0

- old
+ new

@@ -2,9 +2,11 @@ require 'avromatic/io/datum_reader' module Avromatic # Subclass AvroTurf::Messaging to use a custom DatumReader for decode. class Messaging < AvroTurf::Messaging + attr_reader :registry + def decode(data, schema_name: nil, namespace: @namespace) readers_schema = schema_name && @schema_store.find(schema_name, namespace) stream = StringIO.new(data) decoder = Avro::IO::BinaryDecoder.new(stream)