const { stream } = require('reactive-steem')
 
stream()
    .blocks
    .subscribe(({ block }) => {
        console.log(block)
    })

const { stream, toTransaction } = require('reactive-steem')
 
stream()
    .blocks
    .pipe(toTransaction)
    .subscribe(({ transaction, block }) => {
        const [opType, op] = transaction.operations[0]
        console.log(opType, op)
    })