class EvilEvents::Core::Events::Serializers::MessagePack::Factory

@api private @since 0.4.0

Public Instance Methods

build_config() click to toggle source

@return [MessagePack::Config]

@api private @since 0.4.0

# File lib/evil_events/core/events/serializers/message_pack/factory.rb, line 12
def build_config
  options = EvilEvents::Core::Bootstrap[:config].settings.serializers.msgpack
  Config.new.tap { |conf| conf.settings.options = options }
end
build_engine(config) click to toggle source

@param config [MessagePack::Config] @raise [EvilEvents::UnrecognizedSerializationEngineError] @return [Base::AbstractEngine]

@api private @since 0.4.0

# File lib/evil_events/core/events/serializers/message_pack/factory.rb, line 23
def build_engine(config)
  Engines.resolve(config.settings.options[:engine]).new(config)
rescue Dry::Container::Error
  raise EvilEvents::UnrecognizedSerializationEngineError
end
build_packer(engine, _config) click to toggle source

@param engine [Base::AbstractEngine] @param config [MessagePack::Config] @return [MessagePack::Packer]

@api private @since 0.4.0

# File lib/evil_events/core/events/serializers/message_pack/factory.rb, line 35
def build_packer(engine, _config)
  Packer.new(engine)
end
build_unpacker(engine, _config) click to toggle source

@param engine [Base::AbstractEngine] @param config [MessagePack::Config] @return [MessagePack::Unpacker]

@api private @since 0.4.0

# File lib/evil_events/core/events/serializers/message_pack/factory.rb, line 45
def build_unpacker(engine, _config)
  Unpacker.new(engine)
end
create_adapter(engine, config, packer, unpacker) click to toggle source

@param engine [Base::AbstractEngine] @param config [MessagePack::Config] @param packer [MessagePack::Packer] @param unpacker [MessagePack::Unpacker]

@api private @since 0.4.0

# File lib/evil_events/core/events/serializers/message_pack/factory.rb, line 56
def create_adapter(engine, config, packer, unpacker)
  MessagePack.new(engine, config, packer, unpacker)
end