@@ -80,7 +80,7 @@ struct InProcessTransportTests {
8080 request: ClientRequest ( message: ( ) ) ,
8181 descriptor: . peerInfo,
8282 serializer: VoidSerializer ( ) ,
83- deserializer: PeerInfoDeserializer ( ) ,
83+ deserializer: JSONDeserializer < PeerInfo > ( ) ,
8484 options: . defaults
8585 ) {
8686 try $0. message
@@ -142,7 +142,7 @@ private struct TestService: RegistrableRPCService {
142142 router. registerHandler (
143143 forMethod: . peerInfo,
144144 deserializer: VoidDeserializer ( ) ,
145- serializer: PeerInfoSerializer ( ) ,
145+ serializer: JSONSerializer < PeerInfo > ( ) ,
146146 handler: {
147147 let response = try await self . peerInfo (
148148 request: ServerRequest < Void > ( stream: $0) ,
@@ -171,22 +171,6 @@ private struct PeerInfo: Codable {
171171 var remote : String
172172}
173173
174- private struct PeerInfoSerializer : MessageSerializer {
175- func serialize< Bytes: GRPCContiguousBytes > ( _ message: PeerInfo ) throws -> Bytes {
176- Bytes ( " \( message. local) \( message. remote) " . utf8)
177- }
178- }
179-
180- private struct PeerInfoDeserializer : MessageDeserializer {
181- func deserialize< Bytes: GRPCContiguousBytes > ( _ serializedMessageBytes: Bytes ) throws -> PeerInfo {
182- let stringPeerInfo = serializedMessageBytes. withUnsafeBytes {
183- String ( decoding: $0, as: UTF8 . self)
184- }
185- let peerInfoComponents = stringPeerInfo. split ( separator: " " )
186- return PeerInfo ( local: String ( peerInfoComponents [ 0 ] ) , remote: String ( peerInfoComponents [ 1 ] ) )
187- }
188- }
189-
190174private struct UTF8Serializer : MessageSerializer {
191175 func serialize< Bytes: GRPCContiguousBytes > ( _ message: String ) throws -> Bytes {
192176 Bytes ( message. utf8)
0 commit comments