Method: CloudI::API#unsubscribe

Defined in:
lib/cloudi.rb

#unsubscribe(pattern) ⇒ Object 



101
102
103
104
105
106
107
108
109
110
 
# File 'lib/cloudi.rb', line 101

def unsubscribe(pattern)
    key = @prefix + pattern
    value = @callbacks.fetch(key, nil)
    API.assert{value != nil}
    value.shift
    if value.empty?
        @callbacks.delete(key)
    end
    send(Erlang.term_to_binary([:unsubscribe, pattern]))
end