# HG changeset patch
# User Sergey Kandaurov <pluknet@nginx.com>
# Date 1430308707 -10800
# Node ID ff49e1c00b35fb28f47677e9ddd0558af537dc96
# Parent  a1c93746570d0cda16230f4be71f7c6100a2449f
Tests: in stream tests, try to read all the data where appropriate.

diff --git a/stream_error_log.t b/stream_error_log.t
--- a/stream_error_log.t
+++ b/stream_error_log.t
@@ -170,10 +170,12 @@ sub stream_get {
 	$peer = '127.0.0.1:8080' unless defined $peer;
 	my $s = stream_connect($peer);
 	stream_write($s, $data);
-	my $r = stream_read($s);
 
-	$s->close;
-	return $r;
+	$data = '';
+	while (my $buf = stream_read($s)) {
+		$data .= $buf;
+	}
+	return $data;
 }
 
 sub stream_connect {
diff --git a/stream_proxy_next_upstream.t b/stream_proxy_next_upstream.t
--- a/stream_proxy_next_upstream.t
+++ b/stream_proxy_next_upstream.t
@@ -85,10 +85,12 @@ sub stream_get {
 
 	my $s = stream_connect($peer);
 	stream_write($s, $data);
-	my $r = stream_read($s);
 
-	$s->close;
-	return $r;
+	$data = '';
+	while (my $buf = stream_read($s)) {
+		$data .= $buf;
+	}
+	return $data;
 }
 
 sub stream_connect {
diff --git a/stream_upstream.t b/stream_upstream.t
--- a/stream_upstream.t
+++ b/stream_upstream.t
@@ -119,10 +119,12 @@ sub stream_get {
 
 	my $s = stream_connect($peer);
 	stream_write($s, $data);
-	my $r = stream_read($s);
 
-	$s->close;
-	return $r;
+	$data = '';
+	while (my $buf = stream_read($s)) {
+		$data .= $buf;
+	}
+	return $data;
 }
 
 sub stream_connect {
diff --git a/stream_upstream_least_conn.t b/stream_upstream_least_conn.t
--- a/stream_upstream_least_conn.t
+++ b/stream_upstream_least_conn.t
@@ -109,10 +109,12 @@ sub stream_get {
 
 	my $s = stream_connect($peer);
 	stream_write($s, $data);
-	my $r = stream_read($s);
 
-	$s->close;
-	return $r;
+	$data = '';
+	while (my $buf = stream_read($s)) {
+		$data .= $buf;
+	}
+	return $data;
 }
 
 sub stream_connect {