Contents

module Turbo::Replay
  module Overrides
    module StreamsChannelBroadcast
      def broadcast_stream_to(*streamables, content:)
        broadcasting =
          stream_name_from(streamables)

        content_with_sequence_number =
          Turbo::Replay::Message.insert(
            broadcasting: broadcasting,
            content: content
          )

        ::ActionCable.server.broadcast(broadcasting, content_with_sequence_number)
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
turbo-replay-0.1.2	lib/turbo/replay/overrides/streams_channel_broadcast.rb
turbo-replay-0.1.1	lib/turbo/replay/overrides/streams_channel_broadcast.rb