test: check that we close the connection when streaming

http/http_test.go

@@ -25,6 +25,7 @@ func TestHTTP(t *testing.T) {
 		err     error
 		sendErr error
 		wait    bool
+		close   bool
 	}
 
 	tcs := []testcase{
@@ -73,7 +74,8 @@ func TestHTTP(t *testing.T) {
 							Reader: bytes.NewBufferString("This is the body of the request!"),
 							Closer: nopCloser{},
 						}, nil)}),
-			vs: []interface{}{"i received:", "This is the body of the request!"},
+			vs:    []interface{}{"i received:", "This is the body of the request!"},
+			close: true,
 		},
 	}
 
@@ -201,6 +203,10 @@ func TestHTTP(t *testing.T) {
 				}
 			}
 
+			if tc.close && !res.(*Response).res.Close {
+				t.Error("expected the connection to be closed by the server but it wasn't")
+			}
+
 			wait, ok := getWaitChan(env)
 			if !ok {
 				t.Fatal("could not get wait chan")