From 2b6078284c2fee85c186a881d8723fe32730ce8a Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Wed, 11 Feb 2015 19:05:22 -0800 Subject: [PATCH] gofmt on end2end_test.go --- test/end2end_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/test/end2end_test.go b/test/end2end_test.go index bcd96129..765162dc 100644 --- a/test/end2end_test.go +++ b/test/end2end_test.go @@ -248,7 +248,7 @@ func TestLargeUnary(t *testing.T) { req := &testpb.SimpleRequest{ ResponseType: testpb.PayloadType_COMPRESSABLE.Enum(), ResponseSize: proto.Int32(int32(respSize)), - Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)) , + Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)), } reply, err := tc.UnaryCall(context.Background(), req) if err != nil { @@ -269,7 +269,7 @@ func TestMetadataUnaryRPC(t *testing.T) { req := &testpb.SimpleRequest{ ResponseType: testpb.PayloadType_COMPRESSABLE.Enum(), ResponseSize: proto.Int32(int32(respSize)), - Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)) , + Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)), } var header, trailer metadata.MD ctx := metadata.NewContext(context.Background(), testMetadata) @@ -291,7 +291,7 @@ func performOneRPC(t *testing.T, tc testpb.TestServiceClient, wg *sync.WaitGroup req := &testpb.SimpleRequest{ ResponseType: testpb.PayloadType_COMPRESSABLE.Enum(), ResponseSize: proto.Int32(int32(respSize)), - Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)) , + Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)), } reply, err := tc.UnaryCall(context.Background(), req) if err != nil { @@ -339,7 +339,7 @@ func TestTimeout(t *testing.T) { req := &testpb.SimpleRequest{ ResponseType: testpb.PayloadType_COMPRESSABLE.Enum(), ResponseSize: proto.Int32(int32(respSize)), - Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)) , + Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)), } // Performs 100 RPCs with various timeout values so that // the RPCs could timeout on different stages of their lifetime. This @@ -361,7 +361,7 @@ func TestCancel(t *testing.T) { req := &testpb.SimpleRequest{ ResponseType: testpb.PayloadType_COMPRESSABLE.Enum(), ResponseSize: proto.Int32(int32(respSize)), - Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)) , + Payload: newPayload(testpb.PayloadType_COMPRESSABLE, int32(argSize)), } ctx, cancel := context.WithCancel(context.Background()) time.AfterFunc(1*time.Millisecond, cancel)