A nodejs toolkit for manipulating streams of JSON objects