dis+/node_modules/@google-cloud/pubsub/build/src/publisher/message-queues.js
/**
     * Starts a timeout to publish any pending messages.
     */
Starts a timeout to publish any pending messages.
Starts a timeout to publish any pending messages .
beginNextPublish() {
        const maxMilliseconds = this.batchOptions.maxMilliseconds;
        const timeWaiting = Date.now() - this.currentBatch.created;
        const delay = Math.max(0, maxMilliseconds - timeWaiting);
        this.pending = setTimeout(() => this.publish(), delay);
    }
beginNextPublish ( ) { const maxMilliseconds = this . batchOptions . maxMilliseconds ; const timeWaiting = Date . now ( ) - this . currentBatch . created ; const delay = Math . max ( 0 , maxMilliseconds - timeWaiting ) ; this . pending = setTimeout ( ( ) => this . publish ( ) , delay ) ; }
Starts a timeout to publish any pending messages.
Starts a timeout to publish any pending messages .