Contents

# frozen_string_literal: true

module AnyCable
  module BroadcastAdapters
    class Base
      def raw_broadcast(_data)
        raise NotImplementedError
      end

      def broadcast(stream, payload)
        raw_broadcast({stream: stream, data: payload}.to_json)
      end

      def broadcast_command(command, **payload)
        raw_broadcast({command: command, payload: payload}.to_json)
      end

      def announce!
        logger.info "Broadcasting via #{self.class.name}"
      end

      private

      def logger
        AnyCable.logger
      end
    end
  end
end

Version data entries

28 entries across 28 versions & 2 rubygems

Version	Path
anycable-core-1.1.0.rc1	lib/anycable/broadcast_adapters/base.rb
anycable-core-1.1.0.pre1	lib/anycable/broadcast_adapters/base.rb
anycable-1.0.3	lib/anycable/broadcast_adapters/base.rb
anycable-1.0.2	lib/anycable/broadcast_adapters/base.rb
anycable-1.0.1	lib/anycable/broadcast_adapters/base.rb
anycable-1.0.0	lib/anycable/broadcast_adapters/base.rb
anycable-1.0.0.rc2	lib/anycable/broadcast_adapters/base.rb
anycable-1.0.0.rc1	lib/anycable/broadcast_adapters/base.rb