Support Streams

[humbao]

Enhance query functionality to apply to streams.

[megawac]

@humbao you can test individual items with underscore query

var myQuery = { ... }, streamedItem = { ... }

let q = _query.parse({
   myQuery
})

q(streamedItem);

I'll leave this open as it should be documented