Commit b25de6e2 authored by Saad Ali's avatar Saad Ali

Merge pull request #9916 from caesarxuchao/streamer

remove string "v1beta1" from streamer_test.go
parents ddf6fa70 271a63f4
...@@ -41,7 +41,7 @@ func TestInputStreamReader(t *testing.T) { ...@@ -41,7 +41,7 @@ func TestInputStreamReader(t *testing.T) {
streamer := &LocationStreamer{ streamer := &LocationStreamer{
Location: u, Location: u,
} }
readCloser, _, _, err := streamer.InputStream("v1beta1", "text/plain") readCloser, _, _, err := streamer.InputStream("", "")
if err != nil { if err != nil {
t.Errorf("Unexpected error when getting stream: %v", err) t.Errorf("Unexpected error when getting stream: %v", err)
return return
...@@ -57,7 +57,7 @@ func TestInputStreamNullLocation(t *testing.T) { ...@@ -57,7 +57,7 @@ func TestInputStreamNullLocation(t *testing.T) {
streamer := &LocationStreamer{ streamer := &LocationStreamer{
Location: nil, Location: nil,
} }
readCloser, _, _, err := streamer.InputStream("v1beta1", "text/plain") readCloser, _, _, err := streamer.InputStream("", "")
if err != nil { if err != nil {
t.Errorf("Unexpected error when getting stream with null location: %v", err) t.Errorf("Unexpected error when getting stream with null location: %v", err)
} }
...@@ -87,7 +87,7 @@ func TestInputStreamContentType(t *testing.T) { ...@@ -87,7 +87,7 @@ func TestInputStreamContentType(t *testing.T) {
Location: location, Location: location,
Transport: fakeTransport("application/json", "hello world"), Transport: fakeTransport("application/json", "hello world"),
} }
readCloser, _, contentType, err := streamer.InputStream("v1beta1", "text/plain") readCloser, _, contentType, err := streamer.InputStream("", "")
if err != nil { if err != nil {
t.Errorf("Unexpected error when getting stream: %v", err) t.Errorf("Unexpected error when getting stream: %v", err)
return return
...@@ -105,7 +105,7 @@ func TestInputStreamTransport(t *testing.T) { ...@@ -105,7 +105,7 @@ func TestInputStreamTransport(t *testing.T) {
Location: location, Location: location,
Transport: fakeTransport("text/plain", message), Transport: fakeTransport("text/plain", message),
} }
readCloser, _, _, err := streamer.InputStream("v1beta1", "text/plain") readCloser, _, _, err := streamer.InputStream("", "")
if err != nil { if err != nil {
t.Errorf("Unexpected error when getting stream: %v", err) t.Errorf("Unexpected error when getting stream: %v", err)
return return
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment