View all @reactivex/ix-es2015-cjs analysis

How to use the @reactivex/ix-es2015-cjs/asynciterable/pipe/flatten.flatten function in @reactivex/ix-es2015-cjs

To help you get started, we’ve selected a few @reactivex/ix-es2015-cjs examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

neo-one-suite / neo-one / packages / neo-one-client-core / src / provider / NEOONEDataProvider.ts View on Github

public iterStorage(address: AddressString): AsyncIterable {
    return AsyncIterableX.from(this.mutableClient.getAllStorage(address).then((res) =&gt; AsyncIterableX.from(res))).pipe(
      // tslint:disable-next-line no-any
      flatten() as any,
      map((storageItem) =&gt; this.convertStorageItem(storageItem)),
    );
  }