Class: DurableStreams::Rails::BroadcastJob

Inherits:

ActiveJob::Base

Object
ActiveJob::Base
DurableStreams::Rails::BroadcastJob

show all

Defined in:: app/jobs/durable_streams/rails/broadcast_job.rb

Instance Method Summary collapse

#perform(stream_name, type:, key:, value:, operation:) ⇒ Object

Instance Method Details

#perform(stream_name, type:, key:, value:, operation:) ⇒ `Object`



8
9
10

# File 'app/jobs/durable_streams/rails/broadcast_job.rb', line 8

def perform(stream_name, type:, key:, value:, operation:)
  DurableStreams.broadcast_event_to stream_name, type: type, key: key, value: value, operation: operation
end