fix transport_test
This commit is contained in:
@ -500,7 +500,7 @@ func TestClientWithMisbehavedServer(t *testing.T) {
|
|||||||
for i := 0; i < int(initialConnWindowSize/initialWindowSize+10); i++ {
|
for i := 0; i < int(initialConnWindowSize/initialWindowSize+10); i++ {
|
||||||
s, err := ct.NewStream(context.Background(), callHdr)
|
s, err := ct.NewStream(context.Background(), callHdr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("Failed to open stream: %v", err)
|
break
|
||||||
}
|
}
|
||||||
if err := ct.Write(s, expectedRequest, &Options{Last: true, Delay: false}); err != nil {
|
if err := ct.Write(s, expectedRequest, &Options{Last: true, Delay: false}); err != nil {
|
||||||
break
|
break
|
||||||
|
Reference in New Issue
Block a user