fix(streams): Fixed minor errors in stream handling