Contents

# frozen_string_literal: true

module LiteCable
  module Server
    module ClientSocket
      # Handle socket subscriptions
      module Subscriptions
        def subscribe(channel, broadcasting)
          LiteCable::Server.subscribers_map
                           .add_subscriber(broadcasting, self, channel)
        end

        def unsubscribe(channel, broadcasting)
          LiteCable::Server.subscribers_map
                           .remove_subscriber(broadcasting, self, channel)
        end

        def unsubscribe_from_all(channel)
          LiteCable::Server.subscribers_map.remove_socket(self, channel)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
litecable-0.5.0	lib/lite_cable/server/client_socket/subscriptions.rb