dis+/node_modules/@google-cloud/pubsub/build/src/publisher/message-queues.js
/**
     * Cancels any pending publishes and calls _publish immediately.
     */
Cancels any pending publishes and calls _publish immediately.
Cancels any pending publishes and calls _publish immediately .
publish(callback) {
        const { messages, callbacks } = this.batch;
        this.batch = new message_batch_1.MessageBatch(this.batchOptions);
        if (this.pending) {
            clearTimeout(this.pending);
            delete this.pending;
        }
        this._publish(messages, callbacks, callback);
    }
publish ( callback ) { const { messages , callbacks } = this . batch ; this . batch = new message_batch_1 . MessageBatch ( this . batchOptions ) ; if ( this . pending ) { clearTimeout ( this . pending ) ; delete this . pending ; } this . _publish ( messages , callbacks , callback ) ; }
Cancels any pending publishes and calls _publish immediately.
Cancels any pending publishes and calls _publish immediately .