2.0.0 - onStream now emits error as first arg for invalid data, publishes #2 and #3