working on error handling to prevent multiple callbacks
end > close
cb > callback
better handling for empty streams
handling empty stream case
adding retries option
close event in error reference
merging in backpressure