Avoid creating extra wrapper streams in flatMapError