Update streams to use pipe instead of util.pump