BinaryEcho.swift 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. /*
  2. * Copyright 2023, gRPC Authors All rights reserved.
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. import GRPCCore
  17. import XCTest
  18. @available(macOS 13, iOS 16, tvOS 16, watchOS 9, *)
  19. struct BinaryEcho: RegistrableRPCService {
  20. func get(
  21. _ request: ServerRequest.Single<[UInt8]>
  22. ) async throws -> ServerResponse.Single<[UInt8]> {
  23. ServerResponse.Single(message: request.message, metadata: request.metadata)
  24. }
  25. func collect(
  26. _ request: ServerRequest.Stream<[UInt8]>
  27. ) async throws -> ServerResponse.Single<[UInt8]> {
  28. let collected = try await request.messages.reduce(into: []) { $0.append(contentsOf: $1) }
  29. return ServerResponse.Single(message: collected, metadata: request.metadata)
  30. }
  31. func expand(
  32. _ request: ServerRequest.Single<[UInt8]>
  33. ) async throws -> ServerResponse.Stream<[UInt8]> {
  34. return ServerResponse.Stream(metadata: request.metadata) {
  35. for byte in request.message {
  36. try await $0.write([byte])
  37. }
  38. return [:]
  39. }
  40. }
  41. func update(
  42. _ request: ServerRequest.Stream<[UInt8]>
  43. ) async throws -> ServerResponse.Stream<[UInt8]> {
  44. return ServerResponse.Stream(metadata: request.metadata) {
  45. for try await message in request.messages {
  46. try await $0.write(message)
  47. }
  48. return [:]
  49. }
  50. }
  51. func registerMethods(with router: inout RPCRouter) {
  52. let serializer = IdentitySerializer()
  53. let deserializer = IdentityDeserializer()
  54. router.registerHandler(
  55. forMethod: Methods.get,
  56. deserializer: deserializer,
  57. serializer: serializer
  58. ) { streamRequest in
  59. let singleRequest = try await ServerRequest.Single(stream: streamRequest)
  60. let singleResponse = try await self.get(singleRequest)
  61. return ServerResponse.Stream(single: singleResponse)
  62. }
  63. router.registerHandler(
  64. forMethod: Methods.collect,
  65. deserializer: deserializer,
  66. serializer: serializer
  67. ) { streamRequest in
  68. let singleResponse = try await self.collect(streamRequest)
  69. return ServerResponse.Stream(single: singleResponse)
  70. }
  71. router.registerHandler(
  72. forMethod: Methods.expand,
  73. deserializer: deserializer,
  74. serializer: serializer
  75. ) { streamRequest in
  76. let singleRequest = try await ServerRequest.Single(stream: streamRequest)
  77. let streamResponse = try await self.expand(singleRequest)
  78. return streamResponse
  79. }
  80. router.registerHandler(
  81. forMethod: Methods.update,
  82. deserializer: deserializer,
  83. serializer: serializer
  84. ) { streamRequest in
  85. let streamResponse = try await self.update(streamRequest)
  86. return streamResponse
  87. }
  88. }
  89. enum Methods {
  90. static let get = MethodDescriptor(service: "echo.Echo", method: "Get")
  91. static let collect = MethodDescriptor(service: "echo.Echo", method: "Collect")
  92. static let expand = MethodDescriptor(service: "echo.Echo", method: "Expand")
  93. static let update = MethodDescriptor(service: "echo.Echo", method: "Update")
  94. }
  95. }