| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682 |
- //
- // DO NOT EDIT.
- // swift-format-ignore-file
- //
- // Generated by the protocol buffer compiler.
- // Source: route_guide.proto
- //
- import GRPC
- import NIO
- import NIOConcurrencyHelpers
- import SwiftProtobuf
- /// Interface exported by the server.
- ///
- /// Usage: instantiate `Routeguide_RouteGuideClient`, then call methods of this protocol to make API calls.
- public protocol Routeguide_RouteGuideClientProtocol: GRPCClient {
- var serviceName: String { get }
- var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? { get }
- func getFeature(
- _ request: Routeguide_Point,
- callOptions: CallOptions?
- ) -> UnaryCall<Routeguide_Point, Routeguide_Feature>
- func listFeatures(
- _ request: Routeguide_Rectangle,
- callOptions: CallOptions?,
- handler: @escaping (Routeguide_Feature) -> Void
- ) -> ServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature>
- func recordRoute(
- callOptions: CallOptions?
- ) -> ClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary>
- func routeChat(
- callOptions: CallOptions?,
- handler: @escaping (Routeguide_RouteNote) -> Void
- ) -> BidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote>
- }
- extension Routeguide_RouteGuideClientProtocol {
- public var serviceName: String {
- return "routeguide.RouteGuide"
- }
- /// A simple RPC.
- ///
- /// Obtains the feature at a given position.
- ///
- /// A feature with an empty name is returned if there's no feature at the given
- /// position.
- ///
- /// - Parameters:
- /// - request: Request to send to GetFeature.
- /// - callOptions: Call options.
- /// - Returns: A `UnaryCall` with futures for the metadata, status and response.
- public func getFeature(
- _ request: Routeguide_Point,
- callOptions: CallOptions? = nil
- ) -> UnaryCall<Routeguide_Point, Routeguide_Feature> {
- return self.makeUnaryCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.getFeature.path,
- request: request,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? []
- )
- }
- /// A server-to-client streaming RPC.
- ///
- /// Obtains the Features available within the given Rectangle. Results are
- /// streamed rather than returned at once (e.g. in a response message with a
- /// repeated field), as the rectangle may cover a large area and contain a
- /// huge number of features.
- ///
- /// - Parameters:
- /// - request: Request to send to ListFeatures.
- /// - callOptions: Call options.
- /// - handler: A closure called when each response is received from the server.
- /// - Returns: A `ServerStreamingCall` with futures for the metadata and status.
- public func listFeatures(
- _ request: Routeguide_Rectangle,
- callOptions: CallOptions? = nil,
- handler: @escaping (Routeguide_Feature) -> Void
- ) -> ServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature> {
- return self.makeServerStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.listFeatures.path,
- request: request,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? [],
- handler: handler
- )
- }
- /// A client-to-server streaming RPC.
- ///
- /// Accepts a stream of Points on a route being traversed, returning a
- /// RouteSummary when traversal is completed.
- ///
- /// Callers should use the `send` method on the returned object to send messages
- /// to the server. The caller should send an `.end` after the final message has been sent.
- ///
- /// - Parameters:
- /// - callOptions: Call options.
- /// - Returns: A `ClientStreamingCall` with futures for the metadata, status and response.
- public func recordRoute(
- callOptions: CallOptions? = nil
- ) -> ClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary> {
- return self.makeClientStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
- )
- }
- /// A Bidirectional streaming RPC.
- ///
- /// Accepts a stream of RouteNotes sent while a route is being traversed,
- /// while receiving other RouteNotes (e.g. from other users).
- ///
- /// Callers should use the `send` method on the returned object to send messages
- /// to the server. The caller should send an `.end` after the final message has been sent.
- ///
- /// - Parameters:
- /// - callOptions: Call options.
- /// - handler: A closure called when each response is received from the server.
- /// - Returns: A `ClientStreamingCall` with futures for the metadata and status.
- public func routeChat(
- callOptions: CallOptions? = nil,
- handler: @escaping (Routeguide_RouteNote) -> Void
- ) -> BidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote> {
- return self.makeBidirectionalStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRouteChatInterceptors() ?? [],
- handler: handler
- )
- }
- }
- @available(*, deprecated)
- extension Routeguide_RouteGuideClient: @unchecked Sendable {}
- @available(*, deprecated, renamed: "Routeguide_RouteGuideNIOClient")
- public final class Routeguide_RouteGuideClient: Routeguide_RouteGuideClientProtocol {
- private let lock = Lock()
- private var _defaultCallOptions: CallOptions
- private var _interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol?
- public let channel: GRPCChannel
- public var defaultCallOptions: CallOptions {
- get { self.lock.withLock { return self._defaultCallOptions } }
- set { self.lock.withLockVoid { self._defaultCallOptions = newValue } }
- }
- public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? {
- get { self.lock.withLock { return self._interceptors } }
- set { self.lock.withLockVoid { self._interceptors = newValue } }
- }
- /// Creates a client for the routeguide.RouteGuide service.
- ///
- /// - Parameters:
- /// - channel: `GRPCChannel` to the service host.
- /// - defaultCallOptions: Options to use for each service call if the user doesn't provide them.
- /// - interceptors: A factory providing interceptors for each RPC.
- public init(
- channel: GRPCChannel,
- defaultCallOptions: CallOptions = CallOptions(),
- interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? = nil
- ) {
- self.channel = channel
- self._defaultCallOptions = defaultCallOptions
- self._interceptors = interceptors
- }
- }
- public struct Routeguide_RouteGuideNIOClient: Routeguide_RouteGuideClientProtocol {
- public var channel: GRPCChannel
- public var defaultCallOptions: CallOptions
- public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol?
- /// Creates a client for the routeguide.RouteGuide service.
- ///
- /// - Parameters:
- /// - channel: `GRPCChannel` to the service host.
- /// - defaultCallOptions: Options to use for each service call if the user doesn't provide them.
- /// - interceptors: A factory providing interceptors for each RPC.
- public init(
- channel: GRPCChannel,
- defaultCallOptions: CallOptions = CallOptions(),
- interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? = nil
- ) {
- self.channel = channel
- self.defaultCallOptions = defaultCallOptions
- self.interceptors = interceptors
- }
- }
- /// Interface exported by the server.
- @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
- public protocol Routeguide_RouteGuideAsyncClientProtocol: GRPCClient {
- static var serviceDescriptor: GRPCServiceDescriptor { get }
- var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? { get }
- func makeGetFeatureCall(
- _ request: Routeguide_Point,
- callOptions: CallOptions?
- ) -> GRPCAsyncUnaryCall<Routeguide_Point, Routeguide_Feature>
- func makeListFeaturesCall(
- _ request: Routeguide_Rectangle,
- callOptions: CallOptions?
- ) -> GRPCAsyncServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature>
- func makeRecordRouteCall(
- callOptions: CallOptions?
- ) -> GRPCAsyncClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary>
- func makeRouteChatCall(
- callOptions: CallOptions?
- ) -> GRPCAsyncBidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote>
- }
- @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
- extension Routeguide_RouteGuideAsyncClientProtocol {
- public static var serviceDescriptor: GRPCServiceDescriptor {
- return Routeguide_RouteGuideClientMetadata.serviceDescriptor
- }
- public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? {
- return nil
- }
- public func makeGetFeatureCall(
- _ request: Routeguide_Point,
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncUnaryCall<Routeguide_Point, Routeguide_Feature> {
- return self.makeAsyncUnaryCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.getFeature.path,
- request: request,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? []
- )
- }
- public func makeListFeaturesCall(
- _ request: Routeguide_Rectangle,
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncServerStreamingCall<Routeguide_Rectangle, Routeguide_Feature> {
- return self.makeAsyncServerStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.listFeatures.path,
- request: request,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? []
- )
- }
- public func makeRecordRouteCall(
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncClientStreamingCall<Routeguide_Point, Routeguide_RouteSummary> {
- return self.makeAsyncClientStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
- )
- }
- public func makeRouteChatCall(
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncBidirectionalStreamingCall<Routeguide_RouteNote, Routeguide_RouteNote> {
- return self.makeAsyncBidirectionalStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRouteChatInterceptors() ?? []
- )
- }
- }
- @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
- extension Routeguide_RouteGuideAsyncClientProtocol {
- public func getFeature(
- _ request: Routeguide_Point,
- callOptions: CallOptions? = nil
- ) async throws -> Routeguide_Feature {
- return try await self.performAsyncUnaryCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.getFeature.path,
- request: request,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? []
- )
- }
- public func listFeatures(
- _ request: Routeguide_Rectangle,
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncResponseStream<Routeguide_Feature> {
- return self.performAsyncServerStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.listFeatures.path,
- request: request,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? []
- )
- }
- public func recordRoute<RequestStream>(
- _ requests: RequestStream,
- callOptions: CallOptions? = nil
- ) async throws -> Routeguide_RouteSummary where RequestStream: Sequence, RequestStream.Element == Routeguide_Point {
- return try await self.performAsyncClientStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
- requests: requests,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
- )
- }
- public func recordRoute<RequestStream>(
- _ requests: RequestStream,
- callOptions: CallOptions? = nil
- ) async throws -> Routeguide_RouteSummary where RequestStream: AsyncSequence & Sendable, RequestStream.Element == Routeguide_Point {
- return try await self.performAsyncClientStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.recordRoute.path,
- requests: requests,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? []
- )
- }
- public func routeChat<RequestStream>(
- _ requests: RequestStream,
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncResponseStream<Routeguide_RouteNote> where RequestStream: Sequence, RequestStream.Element == Routeguide_RouteNote {
- return self.performAsyncBidirectionalStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
- requests: requests,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRouteChatInterceptors() ?? []
- )
- }
- public func routeChat<RequestStream>(
- _ requests: RequestStream,
- callOptions: CallOptions? = nil
- ) -> GRPCAsyncResponseStream<Routeguide_RouteNote> where RequestStream: AsyncSequence & Sendable, RequestStream.Element == Routeguide_RouteNote {
- return self.performAsyncBidirectionalStreamingCall(
- path: Routeguide_RouteGuideClientMetadata.Methods.routeChat.path,
- requests: requests,
- callOptions: callOptions ?? self.defaultCallOptions,
- interceptors: self.interceptors?.makeRouteChatInterceptors() ?? []
- )
- }
- }
- @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
- public struct Routeguide_RouteGuideAsyncClient: Routeguide_RouteGuideAsyncClientProtocol {
- public var channel: GRPCChannel
- public var defaultCallOptions: CallOptions
- public var interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol?
- public init(
- channel: GRPCChannel,
- defaultCallOptions: CallOptions = CallOptions(),
- interceptors: Routeguide_RouteGuideClientInterceptorFactoryProtocol? = nil
- ) {
- self.channel = channel
- self.defaultCallOptions = defaultCallOptions
- self.interceptors = interceptors
- }
- }
- public protocol Routeguide_RouteGuideClientInterceptorFactoryProtocol: Sendable {
- /// - Returns: Interceptors to use when invoking 'getFeature'.
- func makeGetFeatureInterceptors() -> [ClientInterceptor<Routeguide_Point, Routeguide_Feature>]
- /// - Returns: Interceptors to use when invoking 'listFeatures'.
- func makeListFeaturesInterceptors() -> [ClientInterceptor<Routeguide_Rectangle, Routeguide_Feature>]
- /// - Returns: Interceptors to use when invoking 'recordRoute'.
- func makeRecordRouteInterceptors() -> [ClientInterceptor<Routeguide_Point, Routeguide_RouteSummary>]
- /// - Returns: Interceptors to use when invoking 'routeChat'.
- func makeRouteChatInterceptors() -> [ClientInterceptor<Routeguide_RouteNote, Routeguide_RouteNote>]
- }
- public enum Routeguide_RouteGuideClientMetadata {
- public static let serviceDescriptor = GRPCServiceDescriptor(
- name: "RouteGuide",
- fullName: "routeguide.RouteGuide",
- methods: [
- Routeguide_RouteGuideClientMetadata.Methods.getFeature,
- Routeguide_RouteGuideClientMetadata.Methods.listFeatures,
- Routeguide_RouteGuideClientMetadata.Methods.recordRoute,
- Routeguide_RouteGuideClientMetadata.Methods.routeChat,
- ]
- )
- public enum Methods {
- public static let getFeature = GRPCMethodDescriptor(
- name: "GetFeature",
- path: "/routeguide.RouteGuide/GetFeature",
- type: GRPCCallType.unary
- )
- public static let listFeatures = GRPCMethodDescriptor(
- name: "ListFeatures",
- path: "/routeguide.RouteGuide/ListFeatures",
- type: GRPCCallType.serverStreaming
- )
- public static let recordRoute = GRPCMethodDescriptor(
- name: "RecordRoute",
- path: "/routeguide.RouteGuide/RecordRoute",
- type: GRPCCallType.clientStreaming
- )
- public static let routeChat = GRPCMethodDescriptor(
- name: "RouteChat",
- path: "/routeguide.RouteGuide/RouteChat",
- type: GRPCCallType.bidirectionalStreaming
- )
- }
- }
- /// Interface exported by the server.
- ///
- /// To build a server, implement a class that conforms to this protocol.
- public protocol Routeguide_RouteGuideProvider: CallHandlerProvider {
- var interceptors: Routeguide_RouteGuideServerInterceptorFactoryProtocol? { get }
- /// A simple RPC.
- ///
- /// Obtains the feature at a given position.
- ///
- /// A feature with an empty name is returned if there's no feature at the given
- /// position.
- func getFeature(request: Routeguide_Point, context: StatusOnlyCallContext) -> EventLoopFuture<Routeguide_Feature>
- /// A server-to-client streaming RPC.
- ///
- /// Obtains the Features available within the given Rectangle. Results are
- /// streamed rather than returned at once (e.g. in a response message with a
- /// repeated field), as the rectangle may cover a large area and contain a
- /// huge number of features.
- func listFeatures(request: Routeguide_Rectangle, context: StreamingResponseCallContext<Routeguide_Feature>) -> EventLoopFuture<GRPCStatus>
- /// A client-to-server streaming RPC.
- ///
- /// Accepts a stream of Points on a route being traversed, returning a
- /// RouteSummary when traversal is completed.
- func recordRoute(context: UnaryResponseCallContext<Routeguide_RouteSummary>) -> EventLoopFuture<(StreamEvent<Routeguide_Point>) -> Void>
- /// A Bidirectional streaming RPC.
- ///
- /// Accepts a stream of RouteNotes sent while a route is being traversed,
- /// while receiving other RouteNotes (e.g. from other users).
- func routeChat(context: StreamingResponseCallContext<Routeguide_RouteNote>) -> EventLoopFuture<(StreamEvent<Routeguide_RouteNote>) -> Void>
- }
- extension Routeguide_RouteGuideProvider {
- public var serviceName: Substring {
- return Routeguide_RouteGuideServerMetadata.serviceDescriptor.fullName[...]
- }
- /// Determines, calls and returns the appropriate request handler, depending on the request's method.
- /// Returns nil for methods not handled by this service.
- public func handle(
- method name: Substring,
- context: CallHandlerContext
- ) -> GRPCServerHandlerProtocol? {
- switch name {
- case "GetFeature":
- return UnaryServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
- responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
- interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? [],
- userFunction: self.getFeature(request:context:)
- )
- case "ListFeatures":
- return ServerStreamingServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_Rectangle>(),
- responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
- interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? [],
- userFunction: self.listFeatures(request:context:)
- )
- case "RecordRoute":
- return ClientStreamingServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
- responseSerializer: ProtobufSerializer<Routeguide_RouteSummary>(),
- interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? [],
- observerFactory: self.recordRoute(context:)
- )
- case "RouteChat":
- return BidirectionalStreamingServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_RouteNote>(),
- responseSerializer: ProtobufSerializer<Routeguide_RouteNote>(),
- interceptors: self.interceptors?.makeRouteChatInterceptors() ?? [],
- observerFactory: self.routeChat(context:)
- )
- default:
- return nil
- }
- }
- }
- /// Interface exported by the server.
- ///
- /// To implement a server, implement an object which conforms to this protocol.
- @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
- public protocol Routeguide_RouteGuideAsyncProvider: CallHandlerProvider, Sendable {
- static var serviceDescriptor: GRPCServiceDescriptor { get }
- var interceptors: Routeguide_RouteGuideServerInterceptorFactoryProtocol? { get }
- /// A simple RPC.
- ///
- /// Obtains the feature at a given position.
- ///
- /// A feature with an empty name is returned if there's no feature at the given
- /// position.
- func getFeature(
- request: Routeguide_Point,
- context: GRPCAsyncServerCallContext
- ) async throws -> Routeguide_Feature
- /// A server-to-client streaming RPC.
- ///
- /// Obtains the Features available within the given Rectangle. Results are
- /// streamed rather than returned at once (e.g. in a response message with a
- /// repeated field), as the rectangle may cover a large area and contain a
- /// huge number of features.
- func listFeatures(
- request: Routeguide_Rectangle,
- responseStream: GRPCAsyncResponseStreamWriter<Routeguide_Feature>,
- context: GRPCAsyncServerCallContext
- ) async throws
- /// A client-to-server streaming RPC.
- ///
- /// Accepts a stream of Points on a route being traversed, returning a
- /// RouteSummary when traversal is completed.
- func recordRoute(
- requestStream: GRPCAsyncRequestStream<Routeguide_Point>,
- context: GRPCAsyncServerCallContext
- ) async throws -> Routeguide_RouteSummary
- /// A Bidirectional streaming RPC.
- ///
- /// Accepts a stream of RouteNotes sent while a route is being traversed,
- /// while receiving other RouteNotes (e.g. from other users).
- func routeChat(
- requestStream: GRPCAsyncRequestStream<Routeguide_RouteNote>,
- responseStream: GRPCAsyncResponseStreamWriter<Routeguide_RouteNote>,
- context: GRPCAsyncServerCallContext
- ) async throws
- }
- @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
- extension Routeguide_RouteGuideAsyncProvider {
- public static var serviceDescriptor: GRPCServiceDescriptor {
- return Routeguide_RouteGuideServerMetadata.serviceDescriptor
- }
- public var serviceName: Substring {
- return Routeguide_RouteGuideServerMetadata.serviceDescriptor.fullName[...]
- }
- public var interceptors: Routeguide_RouteGuideServerInterceptorFactoryProtocol? {
- return nil
- }
- public func handle(
- method name: Substring,
- context: CallHandlerContext
- ) -> GRPCServerHandlerProtocol? {
- switch name {
- case "GetFeature":
- return GRPCAsyncServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
- responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
- interceptors: self.interceptors?.makeGetFeatureInterceptors() ?? [],
- wrapping: { try await self.getFeature(request: $0, context: $1) }
- )
- case "ListFeatures":
- return GRPCAsyncServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_Rectangle>(),
- responseSerializer: ProtobufSerializer<Routeguide_Feature>(),
- interceptors: self.interceptors?.makeListFeaturesInterceptors() ?? [],
- wrapping: { try await self.listFeatures(request: $0, responseStream: $1, context: $2) }
- )
- case "RecordRoute":
- return GRPCAsyncServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_Point>(),
- responseSerializer: ProtobufSerializer<Routeguide_RouteSummary>(),
- interceptors: self.interceptors?.makeRecordRouteInterceptors() ?? [],
- wrapping: { try await self.recordRoute(requestStream: $0, context: $1) }
- )
- case "RouteChat":
- return GRPCAsyncServerHandler(
- context: context,
- requestDeserializer: ProtobufDeserializer<Routeguide_RouteNote>(),
- responseSerializer: ProtobufSerializer<Routeguide_RouteNote>(),
- interceptors: self.interceptors?.makeRouteChatInterceptors() ?? [],
- wrapping: { try await self.routeChat(requestStream: $0, responseStream: $1, context: $2) }
- )
- default:
- return nil
- }
- }
- }
- public protocol Routeguide_RouteGuideServerInterceptorFactoryProtocol: Sendable {
- /// - Returns: Interceptors to use when handling 'getFeature'.
- /// Defaults to calling `self.makeInterceptors()`.
- func makeGetFeatureInterceptors() -> [ServerInterceptor<Routeguide_Point, Routeguide_Feature>]
- /// - Returns: Interceptors to use when handling 'listFeatures'.
- /// Defaults to calling `self.makeInterceptors()`.
- func makeListFeaturesInterceptors() -> [ServerInterceptor<Routeguide_Rectangle, Routeguide_Feature>]
- /// - Returns: Interceptors to use when handling 'recordRoute'.
- /// Defaults to calling `self.makeInterceptors()`.
- func makeRecordRouteInterceptors() -> [ServerInterceptor<Routeguide_Point, Routeguide_RouteSummary>]
- /// - Returns: Interceptors to use when handling 'routeChat'.
- /// Defaults to calling `self.makeInterceptors()`.
- func makeRouteChatInterceptors() -> [ServerInterceptor<Routeguide_RouteNote, Routeguide_RouteNote>]
- }
- public enum Routeguide_RouteGuideServerMetadata {
- public static let serviceDescriptor = GRPCServiceDescriptor(
- name: "RouteGuide",
- fullName: "routeguide.RouteGuide",
- methods: [
- Routeguide_RouteGuideServerMetadata.Methods.getFeature,
- Routeguide_RouteGuideServerMetadata.Methods.listFeatures,
- Routeguide_RouteGuideServerMetadata.Methods.recordRoute,
- Routeguide_RouteGuideServerMetadata.Methods.routeChat,
- ]
- )
- public enum Methods {
- public static let getFeature = GRPCMethodDescriptor(
- name: "GetFeature",
- path: "/routeguide.RouteGuide/GetFeature",
- type: GRPCCallType.unary
- )
- public static let listFeatures = GRPCMethodDescriptor(
- name: "ListFeatures",
- path: "/routeguide.RouteGuide/ListFeatures",
- type: GRPCCallType.serverStreaming
- )
- public static let recordRoute = GRPCMethodDescriptor(
- name: "RecordRoute",
- path: "/routeguide.RouteGuide/RecordRoute",
- type: GRPCCallType.clientStreaming
- )
- public static let routeChat = GRPCMethodDescriptor(
- name: "RouteChat",
- path: "/routeguide.RouteGuide/RouteChat",
- type: GRPCCallType.bidirectionalStreaming
- )
- }
- }
|