diff --git a/lib/streamy/event_handler.rb b/lib/streamy/event_handler.rb index 561fd5a..e8b4328 100644 --- a/lib/streamy/event_handler.rb +++ b/lib/streamy/event_handler.rb @@ -1,4 +1,5 @@ require "active_support/core_ext/hash/indifferent_access" +require "ostruct" module Streamy class EventHandler diff --git a/streamy.gemspec b/streamy.gemspec index 020fd81..3293c9b 100644 --- a/streamy.gemspec +++ b/streamy.gemspec @@ -45,4 +45,5 @@ Gem::Specification.new do |spec| # rubocop:disable Metrics/BlockLength spec.add_dependency "avro_turf", "~> 1.3.0" spec.add_dependency "waterdrop", ">= 2.4.10", "< 3.0.0" spec.add_dependency "webmock", "~> 3.3" + spec.add_dependency "ostruct" end diff --git a/test/avro_deserializer_test.rb b/test/avro_deserializer_test.rb index 3eb4600..68a81bd 100644 --- a/test/avro_deserializer_test.rb +++ b/test/avro_deserializer_test.rb @@ -1,6 +1,7 @@ require "test_helper" require "avro_turf/test/fake_confluent_schema_registry_server" require "webmock/minitest" +require "ostruct" module Streamy class AvroDeserializerTest < Minitest::Test