route_guide.grpc.swift 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682
  1. //
  2. // DO NOT EDIT.
  3. // swift-format-ignore-file
  4. //
  5. // Generated by the protocol buffer compiler.
  6. // Source: route_guide.proto
  7. //
  8. import GRPC
  9. import NIO
  10. import NIOConcurrencyHelpers
  11. import SwiftProtobuf
  12. /// Interface exported by the server.
  13. ///
  14. /// Usage: instantiate `Routeguide_RouteGuideClient`, then call methods of this protocol to make API calls.
  15. public protocol Routeguide_RouteGuideClientProtocol: GRPCClient {
  16. var serviceName: String { get }
  17. var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? { get }
  18. func getFeature(
  19. _ request: Routeguide_Point,
  20. callOptions: CallOptions?
  21. ) -> UnaryCall<Routeguide_Point, Routeguide_Feature>
  22. func listFeatures(
  23. _ request: Routeguide_Rectangle,
  24. callOptions: CallOptions?,
  25. handler: @escaping (Routeguide_Feature) -> Void
  26. ) -> ServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature>
  27. func recordRoute(
  28. callOptions: CallOptions?
  29. ) -> ClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary>
  30. func routeChat(
  31. callOptions: CallOptions?,
  32. handler: @escaping (Routeguide_RouteNote) -> Void
  33. ) -> BidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote>
  34. }
  35. extension Routeguide_RouteGuideClientProtocol {
  36. public var serviceName: String {
  37. return "routeguide.RouteGuide"
  38. }
  39. /// A simple RPC.
  40. ///
  41. /// Obtains the feature at a given position.
  42. ///
  43. /// A feature with an empty name is returned if there's no feature at the given
  44. /// position.
  45. ///
  46. /// - Parameters:
  47. /// - request: Request to send to GetFeature.
  48. /// - callOptions: Call options.
  49. /// - Returns: A `UnaryCall` with futures for the metadata, status and response.
  50. public func getFeature(
  51. _ request: Routeguide_Point,
  52. callOptions: CallOptions? = nil
  53. ) -> UnaryCall<Routeguide_Point, Routeguide_Feature> {
  54. return self.makeUnaryCall(
  55. path: Routeguide_RouteGuideClientMetadata.Methods.getFeature.path,
  56. request: request,
  57. callOptions: callOptions ?? self.defaultCallOptions,
  58. interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? []
  59. )
  60. }
  61. /// A server-to-client streaming RPC.
  62. ///
  63. /// Obtains the Features available within the given Rectangle. Results are
  64. /// streamed rather than returned at once (e.g. in a response message with a
  65. /// repeated field), as the rectangle may cover a large area and contain a
  66. /// huge number of features.
  67. ///
  68. /// - Parameters:
  69. /// - request: Request to send to ListFeatures.
  70. /// - callOptions: Call options.
  71. /// - handler: A closure called when each response is received from the server.
  72. /// - Returns: A `ServerStreamingCall` with futures for the metadata and status.
  73. public func listFeatures(
  74. _ request: Routeguide_Rectangle,
  75. callOptions: CallOptions? = nil,
  76. handler: @escaping (Routeguide_Feature) -> Void
  77. ) -> ServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature> {
  78. return self.makeServerStreamingCall(
  79. path: Routeguide_RouteGuideClientMetadata.Methods.listFeatures.path,
  80. request: request,
  81. callOptions: callOptions ?? self.defaultCallOptions,
  82. interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? [],
  83. handler: handler
  84. )
  85. }
  86. /// A client-to-server streaming RPC.
  87. ///
  88. /// Accepts a stream of Points on a route being traversed, returning a
  89. /// RouteSummary when traversal is completed.
  90. ///
  91. /// Callers should use the `send` method on the returned object to send messages
  92. /// to the server. The caller should send an `.end` after the final message has been sent.
  93. ///
  94. /// - Parameters:
  95. /// - callOptions: Call options.
  96. /// - Returns: A `ClientStreamingCall` with futures for the metadata, status and response.
  97. public func recordRoute(
  98. callOptions: CallOptions? = nil
  99. ) -> ClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary> {
  100. return self.makeClientStreamingCall(
  101. path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
  102. callOptions: callOptions ?? self.defaultCallOptions,
  103. interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
  104. )
  105. }
  106. /// A Bidirectional streaming RPC.
  107. ///
  108. /// Accepts a stream of RouteNotes sent while a route is being traversed,
  109. /// while receiving other RouteNotes (e.g. from other users).
  110. ///
  111. /// Callers should use the `send` method on the returned object to send messages
  112. /// to the server. The caller should send an `.end` after the final message has been sent.
  113. ///
  114. /// - Parameters:
  115. /// - callOptions: Call options.
  116. /// - handler: A closure called when each response is received from the server.
  117. /// - Returns: A `ClientStreamingCall` with futures for the metadata and status.
  118. public func routeChat(
  119. callOptions: CallOptions? = nil,
  120. handler: @escaping (Routeguide_RouteNote) -> Void
  121. ) -> BidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote> {
  122. return self.makeBidirectionalStreamingCall(
  123. path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
  124. callOptions: callOptions ?? self.defaultCallOptions,
  125. interceptors: self.interceptors?.makeRouteChatInterceptors() ?? [],
  126. handler: handler
  127. )
  128. }
  129. }
  130. @available(*, deprecated)
  131. extension Routeguide_RouteGuideClient: @unchecked Sendable {}
  132. @available(*, deprecated, renamed: "Routeguide_RouteGuideNIOClient")
  133. public final class Routeguide_RouteGuideClient: Routeguide_RouteGuideClientProtocol {
  134. private let lock = Lock()
  135. private var _defaultCallOptions: CallOptions
  136. private var _interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol?
  137. public let channel: GRPCChannel
  138. public var defaultCallOptions: CallOptions {
  139. get { self.lock.withLock { return self._defaultCallOptions } }
  140. set { self.lock.withLockVoid { self._defaultCallOptions = newValue } }
  141. }
  142. public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? {
  143. get { self.lock.withLock { return self._interceptors } }
  144. set { self.lock.withLockVoid { self._interceptors = newValue } }
  145. }
  146. /// Creates a client for the routeguide.RouteGuide service.
  147. ///
  148. /// - Parameters:
  149. /// - channel: `GRPCChannel` to the service host.
  150. /// - defaultCallOptions: Options to use for each service call if the user doesn't provide them.
  151. /// - interceptors: A factory providing interceptors for each RPC.
  152. public init(
  153. channel: GRPCChannel,
  154. defaultCallOptions: CallOptions = CallOptions(),
  155. interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? = nil
  156. ) {
  157. self.channel = channel
  158. self._defaultCallOptions = defaultCallOptions
  159. self._interceptors = interceptors
  160. }
  161. }
  162. public struct Routeguide_RouteGuideNIOClient: Routeguide_RouteGuideClientProtocol {
  163. public var channel: GRPCChannel
  164. public var defaultCallOptions: CallOptions
  165. public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol?
  166. /// Creates a client for the routeguide.RouteGuide service.
  167. ///
  168. /// - Parameters:
  169. /// - channel: `GRPCChannel` to the service host.
  170. /// - defaultCallOptions: Options to use for each service call if the user doesn't provide them.
  171. /// - interceptors: A factory providing interceptors for each RPC.
  172. public init(
  173. channel: GRPCChannel,
  174. defaultCallOptions: CallOptions = CallOptions(),
  175. interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? = nil
  176. ) {
  177. self.channel = channel
  178. self.defaultCallOptions = defaultCallOptions
  179. self.interceptors = interceptors
  180. }
  181. }
  182. /// Interface exported by the server.
  183. @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
  184. public protocol Routeguide_RouteGuideAsyncClientProtocol: GRPCClient {
  185. static var serviceDescriptor: GRPCServiceDescriptor { get }
  186. var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? { get }
  187. func makeGetFeatureCall(
  188. _ request: Routeguide_Point,
  189. callOptions: CallOptions?
  190. ) -> GRPCAsyncUnaryCall<Routeguide_Point, Routeguide_Feature>
  191. func makeListFeaturesCall(
  192. _ request: Routeguide_Rectangle,
  193. callOptions: CallOptions?
  194. ) -> GRPCAsyncServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature>
  195. func makeRecordRouteCall(
  196. callOptions: CallOptions?
  197. ) -> GRPCAsyncClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary>
  198. func makeRouteChatCall(
  199. callOptions: CallOptions?
  200. ) -> GRPCAsyncBidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote>
  201. }
  202. @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
  203. extension Routeguide_RouteGuideAsyncClientProtocol {
  204. public static var serviceDescriptor: GRPCServiceDescriptor {
  205. return Routeguide_RouteGuideClientMetadata.serviceDescriptor
  206. }
  207. public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? {
  208. return nil
  209. }
  210. public func makeGetFeatureCall(
  211. _ request: Routeguide_Point,
  212. callOptions: CallOptions? = nil
  213. ) -> GRPCAsyncUnaryCall<Routeguide_Point, Routeguide_Feature> {
  214. return self.makeAsyncUnaryCall(
  215. path: Routeguide_RouteGuideClientMetadata.Methods.getFeature.path,
  216. request: request,
  217. callOptions: callOptions ?? self.defaultCallOptions,
  218. interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? []
  219. )
  220. }
  221. public func makeListFeaturesCall(
  222. _ request: Routeguide_Rectangle,
  223. callOptions: CallOptions? = nil
  224. ) -> GRPCAsyncServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature> {
  225. return self.makeAsyncServerStreamingCall(
  226. path: Routeguide_RouteGuideClientMetadata.Methods.listFeatures.path,
  227. request: request,
  228. callOptions: callOptions ?? self.defaultCallOptions,
  229. interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? []
  230. )
  231. }
  232. public func makeRecordRouteCall(
  233. callOptions: CallOptions? = nil
  234. ) -> GRPCAsyncClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary> {
  235. return self.makeAsyncClientStreamingCall(
  236. path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
  237. callOptions: callOptions ?? self.defaultCallOptions,
  238. interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
  239. )
  240. }
  241. public func makeRouteChatCall(
  242. callOptions: CallOptions? = nil
  243. ) -> GRPCAsyncBidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote> {
  244. return self.makeAsyncBidirectionalStreamingCall(
  245. path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
  246. callOptions: callOptions ?? self.defaultCallOptions,
  247. interceptors: self.interceptors?.makeRouteChatInterceptors() ?? []
  248. )
  249. }
  250. }
  251. @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
  252. extension Routeguide_RouteGuideAsyncClientProtocol {
  253. public func getFeature(
  254. _ request: Routeguide_Point,
  255. callOptions: CallOptions? = nil
  256. ) async throws -> Routeguide_Feature {
  257. return try await self.performAsyncUnaryCall(
  258. path: Routeguide_RouteGuideClientMetadata.Methods.getFeature.path,
  259. request: request,
  260. callOptions: callOptions ?? self.defaultCallOptions,
  261. interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? []
  262. )
  263. }
  264. public func listFeatures(
  265. _ request: Routeguide_Rectangle,
  266. callOptions: CallOptions? = nil
  267. ) -> GRPCAsyncResponseStream<Routeguide_Feature> {
  268. return self.performAsyncServerStreamingCall(
  269. path: Routeguide_RouteGuideClientMetadata.Methods.listFeatures.path,
  270. request: request,
  271. callOptions: callOptions ?? self.defaultCallOptions,
  272. interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? []
  273. )
  274. }
  275. public func recordRoute<RequestStream>(
  276. _ requests: RequestStream,
  277. callOptions: CallOptions? = nil
  278. ) async throws -> Routeguide_RouteSummary where RequestStream: Sequence, RequestStream.Element == Routeguide_Point {
  279. return try await self.performAsyncClientStreamingCall(
  280. path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
  281. requests: requests,
  282. callOptions: callOptions ?? self.defaultCallOptions,
  283. interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
  284. )
  285. }
  286. public func recordRoute<RequestStream>(
  287. _ requests: RequestStream,
  288. callOptions: CallOptions? = nil
  289. ) async throws -> Routeguide_RouteSummary where RequestStream: AsyncSequence & Sendable, RequestStream.Element == Routeguide_Point {
  290. return try await self.performAsyncClientStreamingCall(
  291. path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
  292. requests: requests,
  293. callOptions: callOptions ?? self.defaultCallOptions,
  294. interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
  295. )
  296. }
  297. public func routeChat<RequestStream>(
  298. _ requests: RequestStream,
  299. callOptions: CallOptions? = nil
  300. ) -> GRPCAsyncResponseStream<Routeguide_RouteNote> where RequestStream: Sequence, RequestStream.Element == Routeguide_RouteNote {
  301. return self.performAsyncBidirectionalStreamingCall(
  302. path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
  303. requests: requests,
  304. callOptions: callOptions ?? self.defaultCallOptions,
  305. interceptors: self.interceptors?.makeRouteChatInterceptors() ?? []
  306. )
  307. }
  308. public func routeChat<RequestStream>(
  309. _ requests: RequestStream,
  310. callOptions: CallOptions? = nil
  311. ) -> GRPCAsyncResponseStream<Routeguide_RouteNote> where RequestStream: AsyncSequence & Sendable, RequestStream.Element == Routeguide_RouteNote {
  312. return self.performAsyncBidirectionalStreamingCall(
  313. path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
  314. requests: requests,
  315. callOptions: callOptions ?? self.defaultCallOptions,
  316. interceptors: self.interceptors?.makeRouteChatInterceptors() ?? []
  317. )
  318. }
  319. }
  320. @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
  321. public struct Routeguide_RouteGuideAsyncClient: Routeguide_RouteGuideAsyncClientProtocol {
  322. public var channel: GRPCChannel
  323. public var defaultCallOptions: CallOptions
  324. public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol?
  325. public init(
  326. channel: GRPCChannel,
  327. defaultCallOptions: CallOptions = CallOptions(),
  328. interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? = nil
  329. ) {
  330. self.channel = channel
  331. self.defaultCallOptions = defaultCallOptions
  332. self.interceptors = interceptors
  333. }
  334. }
  335. public protocol Routeguide_RouteGuideClientInterceptorFactoryProtocol: Sendable {
  336. /// - Returns: Interceptors to use when invoking 'getFeature'.
  337. func makeGetFeatureInterceptors() -> [ClientInterceptor<Routeguide_Point, Routeguide_Feature>]
  338. /// - Returns: Interceptors to use when invoking 'listFeatures'.
  339. func makeListFeaturesInterceptors() -> [ClientInterceptor<Routeguide_Rectangle, Routeguide_Feature>]
  340. /// - Returns: Interceptors to use when invoking 'recordRoute'.
  341. func makeRecordRouteInterceptors() -> [ClientInterceptor<Routeguide_Point, Routeguide_RouteSummary>]
  342. /// - Returns: Interceptors to use when invoking 'routeChat'.
  343. func makeRouteChatInterceptors() -> [ClientInterceptor<Routeguide_RouteNote, Routeguide_RouteNote>]
  344. }
  345. public enum Routeguide_RouteGuideClientMetadata {
  346. public static let serviceDescriptor = GRPCServiceDescriptor(
  347. name: "RouteGuide",
  348. fullName: "routeguide.RouteGuide",
  349. methods: [
  350. Routeguide_RouteGuideClientMetadata.Methods.getFeature,
  351. Routeguide_RouteGuideClientMetadata.Methods.listFeatures,
  352. Routeguide_RouteGuideClientMetadata.Methods.recordRoute,
  353. Routeguide_RouteGuideClientMetadata.Methods.routeChat,
  354. ]
  355. )
  356. public enum Methods {
  357. public static let getFeature = GRPCMethodDescriptor(
  358. name: "GetFeature",
  359. path: "/routeguide.RouteGuide/GetFeature",
  360. type: GRPCCallType.unary
  361. )
  362. public static let listFeatures = GRPCMethodDescriptor(
  363. name: "ListFeatures",
  364. path: "/routeguide.RouteGuide/ListFeatures",
  365. type: GRPCCallType.serverStreaming
  366. )
  367. public static let recordRoute = GRPCMethodDescriptor(
  368. name: "RecordRoute",
  369. path: "/routeguide.RouteGuide/RecordRoute",
  370. type: GRPCCallType.clientStreaming
  371. )
  372. public static let routeChat = GRPCMethodDescriptor(
  373. name: "RouteChat",
  374. path: "/routeguide.RouteGuide/RouteChat",
  375. type: GRPCCallType.bidirectionalStreaming
  376. )
  377. }
  378. }
  379. /// Interface exported by the server.
  380. ///
  381. /// To build a server, implement a class that conforms to this protocol.
  382. public protocol Routeguide_RouteGuideProvider: CallHandlerProvider {
  383. var interceptors: Routeguide_RouteGuideServerInterceptorFactoryProtocol? { get }
  384. /// A simple RPC.
  385. ///
  386. /// Obtains the feature at a given position.
  387. ///
  388. /// A feature with an empty name is returned if there's no feature at the given
  389. /// position.
  390. func getFeature(request: Routeguide_Point, context: StatusOnlyCallContext) -> EventLoopFuture<Routeguide_Feature>
  391. /// A server-to-client streaming RPC.
  392. ///
  393. /// Obtains the Features available within the given Rectangle. Results are
  394. /// streamed rather than returned at once (e.g. in a response message with a
  395. /// repeated field), as the rectangle may cover a large area and contain a
  396. /// huge number of features.
  397. func listFeatures(request: Routeguide_Rectangle, context: StreamingResponseCallContext<Routeguide_Feature>) -> EventLoopFuture<GRPCStatus>
  398. /// A client-to-server streaming RPC.
  399. ///
  400. /// Accepts a stream of Points on a route being traversed, returning a
  401. /// RouteSummary when traversal is completed.
  402. func recordRoute(context: UnaryResponseCallContext<Routeguide_RouteSummary>) -> EventLoopFuture<(StreamEvent<Routeguide_Point>) -> Void>
  403. /// A Bidirectional streaming RPC.
  404. ///
  405. /// Accepts a stream of RouteNotes sent while a route is being traversed,
  406. /// while receiving other RouteNotes (e.g. from other users).
  407. func routeChat(context: StreamingResponseCallContext<Routeguide_RouteNote>) -> EventLoopFuture<(StreamEvent<Routeguide_RouteNote>) -> Void>
  408. }
  409. extension Routeguide_RouteGuideProvider {
  410. public var serviceName: Substring {
  411. return Routeguide_RouteGuideServerMetadata.serviceDescriptor.fullName[...]
  412. }
  413. /// Determines, calls and returns the appropriate request handler, depending on the request's method.
  414. /// Returns nil for methods not handled by this service.
  415. public func handle(
  416. method name: Substring,
  417. context: CallHandlerContext
  418. ) -> GRPCServerHandlerProtocol? {
  419. switch name {
  420. case "GetFeature":
  421. return UnaryServerHandler(
  422. context: context,
  423. requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
  424. responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
  425. interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? [],
  426. userFunction: self.getFeature(request:context:)
  427. )
  428. case "ListFeatures":
  429. return ServerStreamingServerHandler(
  430. context: context,
  431. requestDeserializer: ProtobufDeserializer<Routeguide_Rectangle>(),
  432. responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
  433. interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? [],
  434. userFunction: self.listFeatures(request:context:)
  435. )
  436. case "RecordRoute":
  437. return ClientStreamingServerHandler(
  438. context: context,
  439. requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
  440. responseSerializer: ProtobufSerializer<Routeguide_RouteSummary>(),
  441. interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? [],
  442. observerFactory: self.recordRoute(context:)
  443. )
  444. case "RouteChat":
  445. return BidirectionalStreamingServerHandler(
  446. context: context,
  447. requestDeserializer: ProtobufDeserializer<Routeguide_RouteNote>(),
  448. responseSerializer: ProtobufSerializer<Routeguide_RouteNote>(),
  449. interceptors: self.interceptors?.makeRouteChatInterceptors() ?? [],
  450. observerFactory: self.routeChat(context:)
  451. )
  452. default:
  453. return nil
  454. }
  455. }
  456. }
  457. /// Interface exported by the server.
  458. ///
  459. /// To implement a server, implement an object which conforms to this protocol.
  460. @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
  461. public protocol Routeguide_RouteGuideAsyncProvider: CallHandlerProvider, Sendable {
  462. static var serviceDescriptor: GRPCServiceDescriptor { get }
  463. var interceptors: Routeguide_RouteGuideServerInterceptorFactoryProtocol? { get }
  464. /// A simple RPC.
  465. ///
  466. /// Obtains the feature at a given position.
  467. ///
  468. /// A feature with an empty name is returned if there's no feature at the given
  469. /// position.
  470. func getFeature(
  471. request: Routeguide_Point,
  472. context: GRPCAsyncServerCallContext
  473. ) async throws -> Routeguide_Feature
  474. /// A server-to-client streaming RPC.
  475. ///
  476. /// Obtains the Features available within the given Rectangle. Results are
  477. /// streamed rather than returned at once (e.g. in a response message with a
  478. /// repeated field), as the rectangle may cover a large area and contain a
  479. /// huge number of features.
  480. func listFeatures(
  481. request: Routeguide_Rectangle,
  482. responseStream: GRPCAsyncResponseStreamWriter<Routeguide_Feature>,
  483. context: GRPCAsyncServerCallContext
  484. ) async throws
  485. /// A client-to-server streaming RPC.
  486. ///
  487. /// Accepts a stream of Points on a route being traversed, returning a
  488. /// RouteSummary when traversal is completed.
  489. func recordRoute(
  490. requestStream: GRPCAsyncRequestStream<Routeguide_Point>,
  491. context: GRPCAsyncServerCallContext
  492. ) async throws -> Routeguide_RouteSummary
  493. /// A Bidirectional streaming RPC.
  494. ///
  495. /// Accepts a stream of RouteNotes sent while a route is being traversed,
  496. /// while receiving other RouteNotes (e.g. from other users).
  497. func routeChat(
  498. requestStream: GRPCAsyncRequestStream<Routeguide_RouteNote>,
  499. responseStream: GRPCAsyncResponseStreamWriter<Routeguide_RouteNote>,
  500. context: GRPCAsyncServerCallContext
  501. ) async throws
  502. }
  503. @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
  504. extension Routeguide_RouteGuideAsyncProvider {
  505. public static var serviceDescriptor: GRPCServiceDescriptor {
  506. return Routeguide_RouteGuideServerMetadata.serviceDescriptor
  507. }
  508. public var serviceName: Substring {
  509. return Routeguide_RouteGuideServerMetadata.serviceDescriptor.fullName[...]
  510. }
  511. public var interceptors: Routeguide_RouteGuideServerInterceptorFactoryProtocol? {
  512. return nil
  513. }
  514. public func handle(
  515. method name: Substring,
  516. context: CallHandlerContext
  517. ) -> GRPCServerHandlerProtocol? {
  518. switch name {
  519. case "GetFeature":
  520. return GRPCAsyncServerHandler(
  521. context: context,
  522. requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
  523. responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
  524. interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? [],
  525. wrapping: { try await self.getFeature(request: $0, context: $1) }
  526. )
  527. case "ListFeatures":
  528. return GRPCAsyncServerHandler(
  529. context: context,
  530. requestDeserializer: ProtobufDeserializer<Routeguide_Rectangle>(),
  531. responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
  532. interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? [],
  533. wrapping: { try await self.listFeatures(request: $0, responseStream: $1, context: $2) }
  534. )
  535. case "RecordRoute":
  536. return GRPCAsyncServerHandler(
  537. context: context,
  538. requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
  539. responseSerializer: ProtobufSerializer<Routeguide_RouteSummary>(),
  540. interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? [],
  541. wrapping: { try await self.recordRoute(requestStream: $0, context: $1) }
  542. )
  543. case "RouteChat":
  544. return GRPCAsyncServerHandler(
  545. context: context,
  546. requestDeserializer: ProtobufDeserializer<Routeguide_RouteNote>(),
  547. responseSerializer: ProtobufSerializer<Routeguide_RouteNote>(),
  548. interceptors: self.interceptors?.makeRouteChatInterceptors() ?? [],
  549. wrapping: { try await self.routeChat(requestStream: $0, responseStream: $1, context: $2) }
  550. )
  551. default:
  552. return nil
  553. }
  554. }
  555. }
  556. public protocol Routeguide_RouteGuideServerInterceptorFactoryProtocol: Sendable {
  557. /// - Returns: Interceptors to use when handling 'getFeature'.
  558. /// Defaults to calling `self.makeInterceptors()`.
  559. func makeGetFeatureInterceptors() -> [ServerInterceptor<Routeguide_Point, Routeguide_Feature>]
  560. /// - Returns: Interceptors to use when handling 'listFeatures'.
  561. /// Defaults to calling `self.makeInterceptors()`.
  562. func makeListFeaturesInterceptors() -> [ServerInterceptor<Routeguide_Rectangle, Routeguide_Feature>]
  563. /// - Returns: Interceptors to use when handling 'recordRoute'.
  564. /// Defaults to calling `self.makeInterceptors()`.
  565. func makeRecordRouteInterceptors() -> [ServerInterceptor<Routeguide_Point, Routeguide_RouteSummary>]
  566. /// - Returns: Interceptors to use when handling 'routeChat'.
  567. /// Defaults to calling `self.makeInterceptors()`.
  568. func makeRouteChatInterceptors() -> [ServerInterceptor<Routeguide_RouteNote, Routeguide_RouteNote>]
  569. }
  570. public enum Routeguide_RouteGuideServerMetadata {
  571. public static let serviceDescriptor = GRPCServiceDescriptor(
  572. name: "RouteGuide",
  573. fullName: "routeguide.RouteGuide",
  574. methods: [
  575. Routeguide_RouteGuideServerMetadata.Methods.getFeature,
  576. Routeguide_RouteGuideServerMetadata.Methods.listFeatures,
  577. Routeguide_RouteGuideServerMetadata.Methods.recordRoute,
  578. Routeguide_RouteGuideServerMetadata.Methods.routeChat,
  579. ]
  580. )
  581. public enum Methods {
  582. public static let getFeature = GRPCMethodDescriptor(
  583. name: "GetFeature",
  584. path: "/routeguide.RouteGuide/GetFeature",
  585. type: GRPCCallType.unary
  586. )
  587. public static let listFeatures = GRPCMethodDescriptor(
  588. name: "ListFeatures",
  589. path: "/routeguide.RouteGuide/ListFeatures",
  590. type: GRPCCallType.serverStreaming
  591. )
  592. public static let recordRoute = GRPCMethodDescriptor(
  593. name: "RecordRoute",
  594. path: "/routeguide.RouteGuide/RecordRoute",
  595. type: GRPCCallType.clientStreaming
  596. )
  597. public static let routeChat = GRPCMethodDescriptor(
  598. name: "RouteChat",
  599. path: "/routeguide.RouteGuide/RouteChat",
  600. type: GRPCCallType.bidirectionalStreaming
  601. )
  602. }
  603. }