var ges = require('ges-client')
 
// 1) Create a connection to a running EventStore
//    using default connection options and credentials
var connection = ges()
    , stream = 'intro-events'
 
// 2) Append events that can be read
connection.on('connect', function() {
    var appendData = {
          expectedVersion: ges.expectedVersion.emptyStream
        , events: [array of events]
            }
    connection.appendToStream(stream, appendData, function(err, appendResult) {
      if(err) return console.log('Ooops!', err) // connection error
  	
      // 3) Read first events from the stream
  	connection.readStreamEventsForward(stream, { start: 0, count: 1 }, function(err, readResult) {
        if(err) return console.log('Ooops!', err) // connection error or stream does not exist
 
        // ta da!
  		console.log(readResult.Events)
  	})
  })
})

var ges = require('ges-client')
 
// 1) Create a connection to a running EventStore
//    using default connection options and credentials
var connection = ges()
    , stream = 'intro-events'
 
// 2) Create a subscription
connection.on('connect', function() {
  var subscription = connection.subscribeToStream(stream)
 
    // 3) Listen for events
  subscription.on('event', function(evt) {
  	// ta da!
  	console.log(evt)
  })
 
    var appendData = {
          expectedVersion: ges.expectedVersion.emptyStream
        , events: [array of events]
            }
    connection.appendToStream(stream, appendData, function(err, appendResult) {
      if(err) return console.log('Ooops!', err) // connection error
  })
})