Sha256: cabb97f7120251556502abfe42bad8ab5bb0313c71d7099d5db0663d196d7588

Contents?: true

Size: 202 Bytes

Versions: 7

Compression:

Stored size: 202 Bytes

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