some slight modifications to make it play nicer with pausing

Author: chrisdickinson

lib/index.js

@@ -1,16 +1,9 @@
 module.exports = parser
 
-var Stream = require('stream').Stream
+var through = require('through')
   , full_parse_expr = require('./expr')
   , Scope = require('./scope')
 
-function create_stream() {
-  var stream = new Stream
-  stream.readable =
-  stream.writable = true
-  return stream
-}
-
 // singleton!
 var Advance = new Object
 
@@ -121,7 +114,7 @@ function parser() {
 
   setup_stative_parsers()
 
-  var stream = create_stream()
+  var stream = through(write, end)
     , check = arguments.length ? [].slice.call(arguments) : []
     , depth = 0
     , state = []
@@ -132,10 +125,6 @@ function parser() {
     , token
     , node
 
-  // setup stream
-  stream.write = write
-  stream.end = end
-  stream.destroy = destroy
 
   // setup state
   state.shift = special_shift
@@ -210,25 +199,13 @@ function parser() {
     }
 
     stream.emit('end')
-    stream.readable = false
-    stream.closed = true
-    stream.emit('close')
-  }
-
-
-  function destroy() {
-    stream.emit('end')
-
-    stream.write = function(){}
-    stream.writable = false
-    stream.emit('close')
   }
 
   function take() {
     if(errored || !state.length)
       return errored
 
-    return token = tokens[0]
+    return (token = tokens[0]) && !stream.paused
   }
 
   // ----- state manipulation --------