dis+/node_modules/@google-cloud/pubsub/build/src/publisher/message-queues.js
/**
     * Tells the queue it is ok to continue publishing messages.
     */
Tells the queue it is ok to continue publishing messages.
Tells the queue it is ok to continue publishing messages .
resumePublishing() {
        delete this.error;
        process.nextTick(() => {
            if (!this.batches.length) {
                this.emit('drain');
            }
        });
    }
resumePublishing ( ) { delete this . error ; process . nextTick ( ( ) => { if ( ! this . batches . length ) { this . emit ( 'drain' ) ; } } ) ; }
Tells the queue it is ok to continue publishing messages.
Tells the queue it is ok to continue publishing messages .
// once this is called, we'll make this object eligible for garbage // collection. by wrapping in nextTick() we'll give users an opportunity // to use it again instead of deleting instantly and then creating a new // instance.