Unsubscribe request
519490
function(subscription_name) {
    request.del(this._endpoint, {
        qs: this.unsubscribeParams()
      }, function(error, response, body) {
        if (!error && response.statusCode == 200) {
          logger.info('facebook -', 'unsubscribed successfully');
        }
      }
    );
  }
983079
function unsubscribe() {
    console.log(' > ', 'init', ['xmlrpc_bin://' + thisHost + ':2031', '']);
    rpcClient.methodCall('init', ['xmlrpc_bin://' + thisHost + ':2031', ''], function (err, res) {
        console.log(err, res);

        process.exit(0);
    });
    setTimeout(function () {
        console.log('force quit');
        process.exit(1);
    }, 1000);
}
494018
def unsubscribe(self, subscription):
        
        params = {'ContentType' : 'JSON',
                  'SubscriptionArn' : subscription}
        response = self.make_request('Unsubscribe', params, '/', 'GET')
        body = response.read()
        if response.status == 200:
            return json.loads(body)
        else:
            boto.log.error('%s %s' % (response.status, response.reason))
            boto.log.error('%s' % body)
            raise self.ResponseError(response.status, response.reason, body)
115702
def unsubscribe(channel, _json_data)
      log_debug "#{self.class} runs 'unsubscribe' method with  #{channel}"
      return unless channel.present?
      forget_channel(channel)
      delete_server_subscribers(channel)
    end
1340869
def unsubscribe_multi(self, topics):
        """"""
        if self.sock == NC.INVALID_SOCKET:
            return NC.ERR_NO_CONN
        
        self.logger.info("UNSUBSCRIBE: %s", ', '.join(topics))
        return self.send_unsubscribe(False, [utf8encode(topic) for topic in topics])
600824
public ApiResponse<Void> unsubscribeWithHttpInfo() throws ApiException {
        com.squareup.okhttp.Call call = unsubscribeValidateBeforeCall(null, null);
        return apiClient.execute(call);
    }
320541
public void unsubscribe( String clientID , String subscriptionName ) throws JMSException
    {
    	String subscriberID = clientID+"-"+subscriptionName;
    	
    	subscriptionsLock.writeLock().lock();
    	try
		{
        	LocalTopicSubscription subscription = subscriptionMap.get(subscriberID);
        	if (subscription == null)
        		return;
        	
        	if (isConsumerRegistered(subscriberID))
        		throw new FFMQException("Subscription "+subscriptionName+" is still in use","SUBSCRIPTION_STILL_IN_USE");
    		
        	subscriptionMap.remove(subscriberID);
        	removeSubscription(subscription);
		}
    	finally
    	{
    		subscriptionsLock.writeLock().unlock();
    	}
    }
237567
def unsubscribe_all(self):
        # type: () -> None
        """"""
        topics = list(self.topics.keys())
        for topic in topics:
            self.unsubscribe(topic)
1312466
public void unsubscribe() {
        final long id = Thread.currentThread().getId();
        queues.remove(id);
        if (subscriberIdentifiers != null) {
            for (Iterator<Entry<Object, Long>> iterator = subscriberIdentifiers.entrySet().iterator(); iterator.hasNext(); ) {
                if (id == iterator.next().getValue()) {
                    iterator.remove();
                    break;
                }
            }
        }
    }
667598
def unsubscribe_from_hub(self, event, callback):
        
        return self._hub("unsubscribe", event, callback, github.GithubObject.NotSet)
513851
def unsubscribe(self):
        
        _LOGGER.info("PubNub unsubscribing")
        self._pubnub.unsubscribe_all()
        self._pubnub.stop()
        self._pubnub = None
1103888
function unsubscribe(handler) {
        for (var i = handlers.length - 1; i >= 0; --i) {
            if (handlers[i] === handler) {
                handlers.splice(i, 1);
            }
        }

        if (handlers.length === 0) {
            window.onerror = _oldOnerrorHandler;
            _onErrorHandlerInstalled = false;
        }
    }
483445
def unsubscribe(self, topic):
        """"""
        if self.sock == NC.INVALID_SOCKET:
            return NC.ERR_NO_CONN
        
        self.logger.info("UNSUBSCRIBE: %s", topic)
        return self.send_unsubscribe(False, [utf8encode(topic)])
1320757
def unsubscribe(self, *args):
        
        if args:
            args = list_or_args(args[0], args[1:])
            channels = self._normalize_keys(dict.fromkeys(args))
        else:
            channels = self.channels
        self.pending_unsubscribe_channels.update(channels)
        return self.execute_command('UNSUBSCRIBE', *args)
1118750
def subscribe(self, subreddit, unsubscribe=False):
        
        data = {'action': 'unsub' if unsubscribe else 'sub',
                'sr_name': six.text_type(subreddit)}
        response = self.request_json(self.config['subscribe'], data=data)
        self.evict(self.config['my_subreddits'])
        return response
875617
function(client, subscriptions, channel, callback, done_callback) {
    if (subscriptions[channel]===undefined)
        return;
    subscriptions[channel].splice(subscriptions[channel].indexOf(callback), 1);
    if (subscriptions[channel].length===0) {
        delete subscriptions[channel];
        client.unsubscribe(channel, function() {
            // If there is a done_callback defined, execute it
            if (done_callback!==undefined) done_callback();
        });
    }
}
114624
function unsubscribe(conn, channels) {
  return this.doUnsubscribe(
    PUBSUB.UNSUBSCRIBE,
    PUBSUB.CHANNELS,
    this._channels, conn, channels);
}