import { ApiRx } from "https://deno.land/x/polkadot@0.2.12/api/rx/index.ts";
Examples
import { switchMap } from 'https://esm.sh/rxjs@7.5.7';
import Api from 'https://deno.land/x/polkadot@0.2.12/api/rx/index.ts';
Api.create()
.pipe(
switchMap((api) =>
api.rpc.chain.subscribeNewHeads()
))
.subscribe((header) => {
console.log(`new block #${header.number.toNumber()}`);
});