var mtop = require('mongotop')
  , stream = mtop({
      	    ipv6: true, 
  		    locks: true, 
            host: 'localhost', 
            port: '27017', 
            username: 'jim', 
            password: 'password', 
            sleep: 30
          })
 
stream.on('data', function(data) {
  //Do things with the data
})
 
stream.on('error', function(error) {
  //Do things with the error
})
 
stream.pipe(someWriteableStream)