 bound = Meteor.bindEnvironment (callback) -> return callback()
 
 events = Npm.require 'events'
+Stream = Npm.require 'stream'
+
 
 class Neo4jListener
   constructor: (listener, @_db) ->

        'POST'
      ,
        (error, results) =>
          # console.log results

          if results?.data
            @__proceedResult result for result in results.data

          else if results?.content
            content = JSON.parse results.content
            @__proceedResult result for result in content

  __transformData: (response, reactive) ->
    if response?.results or response?.errors
      unless response.exception
        parsed = []
        for result in response.results
          if result?.data
            parsed = parsed.concat @__parseResponse result.data, result.columns, reactive
        return parsed
      else
        return response.exception

