Contents

module Umbra
  class SynchronousPublisher
    def self.call(env, response, encoder: Umbra.encoder, redis: Umbra.redis)
      redis.publish(Umbra::CHANNEL, encoder.call(env, response))
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
umbra-rb-0.2.0	lib/umbra/synchronous_publisher.rb
umbra-rb-0.1.5.pre	lib/umbra/synchronous_publisher.rb
umbra-rb-0.1.4.pre	lib/umbra/synchronous_publisher.rb
umbra-rb-0.1.3.pre	lib/umbra/synchronous_publisher.rb
umbra-rb-0.1.2.pre	lib/umbra/synchronous_publisher.rb
umbra-rb-0.1.1.pre	lib/umbra/synchronous_publisher.rb
umbra-rb-0.1.0.pre	lib/umbra/synchronous_publisher.rb