subscribeHeaders method

Stream<BlockHeader> subscribeHeaders()

Implementation

Stream<BlockHeader> subscribeHeaders() {
  var methodPrefix = 'blockchain.headers';

  // If this is the first time, register
  registerSubscribable(methodPrefix, 0);

  return subscribe(methodPrefix)
      .asyncMap((item) => BlockHeader(item['hex'], item['height']));
}