Description
As @wmhilton noted:
Your module exports an EventEmitter, not a stream.... I'm really into using stream facilities at the moment, like mississippi, and since
level-graph
has adb.putStream()
function, I am taking thechanges-stream
stream, piping it through a map function, piping that into the database.
I've had a hard time making sense of how to use streams. They are conceptually simple, but implementation is another story. The stream implementation/interface has changed three times in node. To make matters worse, node hipsters eschew the built-in node streams in favor of userland modules for reasons that I don't fully understand.
So.. if anyone wants to work on making this package expose the same (or similar) interface while using real streams under the hood, I would be delighted.