@@ -37,7 +37,7 @@ private import struct Foundation.Data
3737/// - call was successful
3838/// - response is non-null
3939struct EmptyUnary : InteroperabilityTest {
40- func run( client: GRPCClient ) async throws {
40+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
4141 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
4242 try await testServiceClient. emptyCall (
4343 request: ClientRequest ( message: Grpc_Testing_Empty ( ) )
@@ -70,7 +70,7 @@ struct EmptyUnary: InteroperabilityTest {
7070/// - clients are free to assert that the response payload body contents are zero and comparing
7171/// the entire response message against a golden response
7272struct LargeUnary : InteroperabilityTest {
73- func run( client: GRPCClient ) async throws {
73+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
7474 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
7575 let request = Grpc_Testing_SimpleRequest . with { request in
7676 request. responseSize = 314_159
@@ -145,7 +145,7 @@ struct LargeUnary: InteroperabilityTest {
145145/// - Clients are free to assert that the response payload body contents are zeros and comparing the
146146/// entire response message against a golden response.
147147class ClientCompressedUnary : InteroperabilityTest {
148- func run( client: GRPCClient ) async throws {
148+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
149149 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
150150 let compressedRequest = Grpc_Testing_SimpleRequest . with { request in
151151 request. expectCompressed = . with { $0. value = true }
@@ -253,7 +253,7 @@ class ClientCompressedUnary: InteroperabilityTest {
253253/// - clients are free to assert that the response payload body contents are zero and comparing the
254254/// entire response message against a golden response
255255class ServerCompressedUnary : InteroperabilityTest {
256- func run( client: GRPCClient ) async throws {
256+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
257257 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
258258
259259 let compressedRequest = Grpc_Testing_SimpleRequest . with { request in
@@ -342,7 +342,7 @@ class ServerCompressedUnary: InteroperabilityTest {
342342/// - call was successful
343343/// - response aggregated_payload_size is 74922
344344struct ClientStreaming : InteroperabilityTest {
345- func run( client: GRPCClient ) async throws {
345+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
346346 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
347347 let request = StreamingClientRequest { writer in
348348 for bytes in [ 27182 , 8 , 1828 , 45904 ] {
@@ -392,7 +392,7 @@ struct ClientStreaming: InteroperabilityTest {
392392/// - clients are free to assert that the response payload body contents are zero and
393393/// comparing the entire response messages against golden responses
394394struct ServerStreaming : InteroperabilityTest {
395- func run( client: GRPCClient ) async throws {
395+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
396396 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
397397 let responseSizes = [ 31415 , 9 , 2653 , 58979 ]
398398 let request = Grpc_Testing_StreamingOutputCallRequest . with { request in
@@ -467,7 +467,7 @@ struct ServerStreaming: InteroperabilityTest {
467467/// - clients are free to assert that the response payload body contents are zero and comparing the
468468/// entire response messages against golden responses
469469class ServerCompressedStreaming : InteroperabilityTest {
470- func run( client: GRPCClient ) async throws {
470+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
471471 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
472472 let request : Grpc_Testing_StreamingOutputCallRequest = . with { request in
473473 request. responseParameters = [
@@ -579,7 +579,7 @@ class ServerCompressedStreaming: InteroperabilityTest {
579579/// - clients are free to assert that the response payload body contents are zero and
580580/// comparing the entire response messages against golden responses
581581struct PingPong : InteroperabilityTest {
582- func run( client: GRPCClient ) async throws {
582+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
583583 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
584584 let ids = AsyncStream . makeStream ( of: Int . self)
585585
@@ -645,7 +645,7 @@ struct PingPong: InteroperabilityTest {
645645/// - call was successful
646646/// - exactly zero responses
647647struct EmptyStream : InteroperabilityTest {
648- func run( client: GRPCClient ) async throws {
648+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
649649 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
650650 let request = StreamingClientRequest< Grpc_Testing_StreamingOutputCallRequest> { _ in }
651651
@@ -716,7 +716,7 @@ struct CustomMetadata: InteroperabilityTest {
716716 try assertEqual ( Array ( values) , [ . binary( self . trailingMetadataValue) ] )
717717 }
718718
719- func run( client: GRPCClient ) async throws {
719+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
720720 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
721721
722722 let unaryRequest = Grpc_Testing_SimpleRequest . with { request in
@@ -823,7 +823,7 @@ struct StatusCodeAndMessage: InteroperabilityTest {
823823 let expectedCode = 2
824824 let expectedMessage = " test status message "
825825
826- func run( client: GRPCClient ) async throws {
826+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
827827 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
828828
829829 let message = Grpc_Testing_SimpleRequest . with {
@@ -897,7 +897,7 @@ struct StatusCodeAndMessage: InteroperabilityTest {
897897/// - received status message is the same as the sent message for Procedure step 1, including all
898898/// whitespace characters
899899struct SpecialStatusMessage : InteroperabilityTest {
900- func run( client: GRPCClient ) async throws {
900+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
901901 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
902902
903903 let responseMessage = " \t \n test with whitespace \r \n and Unicode BMP ☺ and non-BMP 😈 \t \n "
@@ -939,7 +939,7 @@ struct SpecialStatusMessage: InteroperabilityTest {
939939/// Client asserts:
940940/// - received status code is 12 (UNIMPLEMENTED)
941941struct UnimplementedMethod : InteroperabilityTest {
942- func run( client: GRPCClient ) async throws {
942+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
943943 let testServiceClient = Grpc_Testing_TestService . Client ( wrapping: client)
944944 try await testServiceClient. unimplementedCall (
945945 request: ClientRequest ( message: Grpc_Testing_Empty ( ) )
@@ -971,7 +971,7 @@ struct UnimplementedMethod: InteroperabilityTest {
971971/// Client asserts:
972972/// - received status code is 12 (UNIMPLEMENTED)
973973struct UnimplementedService : InteroperabilityTest {
974- func run( client: GRPCClient ) async throws {
974+ func run< Transport : ClientTransport > ( client: GRPCClient < Transport > ) async throws {
975975 let unimplementedServiceClient = Grpc_Testing_UnimplementedService . Client ( wrapping: client)
976976 try await unimplementedServiceClient. unimplementedCall (
977977 request: ClientRequest ( message: Grpc_Testing_Empty ( ) )
0 commit comments