How to use the @reactivex/ix-es2015-cjs/asynciterable/pipe/filter.filter 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.

github neo-one-suite / neo-one / packages / neo-one-client-core / src / sc / createSmartContract.ts View on Github external
const iterLogs = (options?: SmartContractIterOptions): AsyncIterable =>
    AsyncIterableX.from(iterActions(options)).pipe(
      map((action) => {
        if (action.type === 'Event') {
          return undefined;
        }

        return action;
      }),
      filter(utils.notNull),
      filter(Boolean),
    );
github neo-one-suite / neo-one / packages / neo-one-client / src / sc / createReadSmartContract.ts View on Github external
const iterLogs = (actionFilter?: BlockFilter): AsyncIterable =>
    AsyncIterableX.from(iterActions(actionFilter)).pipe(
      map((action) => {
        if (action.type === 'Event') {
          return undefined;
        }

        return action;
      }),
      filter(Boolean),
    );
github neo-one-suite / neo-one / packages / neo-one-client-core / src / sc / createSmartContract.ts View on Github external
const iterActionsRaw = ({
    network = client.getCurrentNetwork(),
    ...iterOptions
  }: SmartContractIterOptions = {}): AsyncIterable =>
    AsyncIterableX.from(client.__iterActionsRaw(network, iterOptions)).pipe(
      filter((action) => action.address === definition.networks[network].address),
    );
github neo-one-suite / neo-one / packages / neo-one-client-core / src / sc / createSmartContract.ts View on Github external
const iterLogs = (options?: SmartContractIterOptions): AsyncIterable =>
    AsyncIterableX.from(iterActions(options)).pipe(
      map((action) => {
        if (action.type === 'Event') {
          return undefined;
        }

        return action;
      }),
      filter(utils.notNull),
      filter(Boolean),
    );
github neo-one-suite / neo-one / packages / neo-one-client / src / sc / createReadSmartContract.ts View on Github external
const iterActionsRaw = (blockFilter: BlockFilter = {}): AsyncIterable =>
    AsyncIterableX.from(client.__iterActionsRaw(blockFilter)).pipe(filter((action) => action.address === address));