diff --git a/packages/light.js/package.json b/packages/light.js/package.json index cec927a6..0a01f87d 100644 --- a/packages/light.js/package.json +++ b/packages/light.js/package.json @@ -1,7 +1,7 @@ { "name": "@parity/light.js", "description": "A high-level reactive JS library optimized for light clients", - "version": "1.0.8", + "version": "1.0.9", "author": "Parity Team ", "license": "MIT", "repository": "https://github.com/paritytech/js-libs/tree/master/packages/light.js", diff --git a/packages/light.js/src/frequency/blocks.ts b/packages/light.js/src/frequency/blocks.ts index dc96022e..5fbe7e02 100644 --- a/packages/light.js/src/frequency/blocks.ts +++ b/packages/light.js/src/frequency/blocks.ts @@ -20,10 +20,10 @@ import { onSyncingChanged$ } from './health'; */ const onEveryBlockWithApi$ = memoizee( (api: any, options: FrequencyObservableOptions) => - onSyncingChanged$(options).pipe( - filter((isSyncing: boolean) => isSyncing === false), - withLatestFrom(createPubsubObservable('eth_blockNumber', options)), - map(([_, blockNumber]) => blockNumber) + createPubsubObservable('eth_blockNumber', options).pipe( + withLatestFrom(onSyncingChanged$(options)), + filter(([_, isSyncing]) => isSyncing === false), + map(([blockNumber]) => blockNumber) ) as Observable, { length: 1 } // Only memoize by api );