We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 87a1565 commit c7ef67aCopy full SHA for c7ef67a
src/stream.coffee
@@ -1,12 +1,13 @@
1
util = require "util"
2
stream = require "readable-stream"
3
-parser = require "./riemann-query"
+Query = require "./riemann-query"
4
extend = util._extend
5
+{ast, fun} = Query
6
7
8
class QueryStream extends stream.Transform
- constructor: (options) ->
9
- @filter = parser query
+ constructor: (query, options = {}) ->
10
+ @filter = fun ast query
11
super extend options, objectMode: true
12
13
_transform: (data, encoding, done) ->
0 commit comments