horizon.transactions()
        .cursor('now')
        .stream({
            onmessage: async function (tx) {
                let operations = await tx.operations();
                console.log(operations.records[0].id);
            }
        });

horizon.operations()
        .cursor('now')
        .stream({
            onmessage: function (op) {
                console.log(op.id);
            }
        });