var StellarSdk = require("stellar-sdk");
var server = new StellarSdk.Server("https://horizon.stellar.org");

var callback = function (resp) {
  console.log(resp);
};

var es = server
  .offers()
  .forAccount("GD3CJYUTZAY6JQF4CEI6Z7VW5O6VNGKZTBYUECTOJPEDTB7I2HZSPI2K")
  .cursor("now")
  .stream({ onmessage: callback });