web3-stream

stream web3 filters & events.

Usage

// List all crypto kitties Transfer event.
const cs = require('co-stream');
const Web3Wallet = require('web3-wallet');
const { Web3EventStream } = require('web3-stream');

const url = 'https://api.myetherapi.com/eth';
const contractAddr = '0x06012c8cf97bead5deae237070f9587f8e7a266d';

const web3 = Web3Wallet.create(null, url);
const CK = web3.eth.loadContract(require('./CryptoKittes.json'), contractAddr);

const fromBlock = 4605167;

(async function () {
  (new Web3EventStream(web3, CK.Transfer, {}, { fromBlock }))
    .pipe(cs.object.each(evt => {
      const { blockNumber, args } = evt;
      args.tokenId = args.tokenId.toString();
      console.log('Block #' + blockNumber, args);
    }));
})().catch(console.error);