diff --git a/packages/web3-core-subscriptions/src/subscription.js b/packages/web3-core-subscriptions/src/subscription.js index cf15b2e827f..0ed229a43ae 100644 --- a/packages/web3-core-subscriptions/src/subscription.js +++ b/packages/web3-core-subscriptions/src/subscription.js @@ -25,6 +25,7 @@ var _ = require('underscore'); var errors = require('web3-core-helpers').errors; var EventEmitter = require('eventemitter3'); +var formatters = require('web3-core-helpers').formatters; function Subscription(options) { EventEmitter.call(this); @@ -227,7 +228,7 @@ Subscription.prototype.subscribe = function() { // a dropped connection may have resulted in gaps in the logs... if (this.lastBlock && _.isObject(this.options.params)){ payload.params[1] = this.options.params - payload.params[1].fromBlock = this.lastBlock +1; + payload.params[1].fromBlock = formatters.inputBlockNumberFormatter(this.lastBlock + 1); } // if id is there unsubscribe first