remove global
callback correctly
return stream so we can stream.end()