Method: MessageBus::HTTPClient#unsubscribe

Defined in:

lib/message_bus/http_client.rb

#unsubscribe(channel) {|data, global_id, message_id| ... } ⇒ Integer

unsubscribes from a channel

If a callback is given, only the specific callback will be unsubscribed.

When the client does not have any channels left, it will stop polling and waits until a new subscription is started.

Examples:

Unsubscribing from a channel

client = MessageBus::HTTPClient.new('http://some.test.com')
callback = -> { |payload| puts payload }
client.subscribe("/test", &callback)
client.unsubscribe("/test")

Unsubscribing a callback from a channel

client.unsubscribe("/test", &callback)

Parameters:

• channel (String) —

  channel to unsubscribe

Yields:

• (data, global_id, message_id) —

  specific callback to unsubscribe

Returns:

• (Integer) —

  the current status of the client

# File 'lib/message_bus/http_client.rb', line 202

def unsubscribe(channel, &callback)
  if callback
    @channels[channel].callbacks.delete(callback)
    remove_channel(channel) if @channels[channel].callbacks.empty?
  else
    remove_channel(channel)
  end

  stop if @channels.empty?
  @status
end