Data loss

[agalazis]

If array size is not exactly divided by batch size then data is not emitted. There might be reason behind that but you might also want to set some timeout for receiving more data in the stream or just mention this in the docs.

[kgryte]

Looks like all that is needed is a flush function which pushes the rest of the data on source close. Will take a PR.

[agalazis]

that's true that seems the most elegant solution

[agalazis]

PR created awaiting code-review /feedback

[agalazis]

@kgryte don't hesitate to comment if I need to change something

[agalazis]

ping xD