channel_manager.rb

  class ChannelManager

    attr_reader :channels, :channel_tokens

    def initialize
      @channels = {}.with_indifferent_access
      @channel_tokens = ChannelTokens.new
    end

    def [](channel)
      @channels[channel] ||= Channel.new channel
    end

    def unsubscribe(connection)
      @channels.each do |channel_name, channel|
        channel.unsubscribe(connection)
      end
    end

    class ChannelTokens

      delegate :synchronize?, to: WebsocketRails

      def initialize
        @tokens = []
      end

      def include?(token)
        if synchronize?
          #check redis here
        else
          @tokens.include?(token)
        end
      end

      def <<(token)
        if synchronize?(token)

        else
          @tokens << token
        end
      end

      def delete(token)
        if synchronize?
          # check redis here
        else
          @tokens.delete(token)
        end
      end

    end