// // DO NOT EDIT. // // Generated by the protocol buffer compiler. // Source: b.proto // // // Copyright 2018, gRPC Authors All rights reserved. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // import GRPC import NIO import SwiftProtobuf /// Usage: instantiate `B_ServiceBClient`, then call methods of this protocol to make API calls. internal protocol B_ServiceBClientProtocol: GRPCClient { var serviceName: String { get } var interceptors: B_ServiceBClientInterceptorFactoryProtocol? { get } func callServiceB( _ request: B_MessageB, callOptions: CallOptions? ) -> UnaryCall } extension B_ServiceBClientProtocol { internal var serviceName: String { return "b.ServiceB" } /// Unary call to CallServiceB /// /// - Parameters: /// - request: Request to send to CallServiceB. /// - callOptions: Call options. /// - Returns: A `UnaryCall` with futures for the metadata, status and response. internal func callServiceB( _ request: B_MessageB, callOptions: CallOptions? = nil ) -> UnaryCall { return self.makeUnaryCall( path: "/b.ServiceB/CallServiceB", request: request, callOptions: callOptions ?? self.defaultCallOptions, interceptors: self.interceptors?.makeCallServiceBInterceptors() ?? [] ) } } internal protocol B_ServiceBClientInterceptorFactoryProtocol { /// - Returns: Interceptors to use when invoking 'callServiceB'. func makeCallServiceBInterceptors() -> [ClientInterceptor] } internal final class B_ServiceBClient: B_ServiceBClientProtocol { internal let channel: GRPCChannel internal var defaultCallOptions: CallOptions internal var interceptors: B_ServiceBClientInterceptorFactoryProtocol? /// Creates a client for the b.ServiceB 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. internal init( channel: GRPCChannel, defaultCallOptions: CallOptions = CallOptions(), interceptors: B_ServiceBClientInterceptorFactoryProtocol? = nil ) { self.channel = channel self.defaultCallOptions = defaultCallOptions self.interceptors = interceptors } } /// To build a server, implement a class that conforms to this protocol. internal protocol B_ServiceBProvider: CallHandlerProvider { var interceptors: B_ServiceBServerInterceptorFactoryProtocol? { get } func callServiceB(request: B_MessageB, context: StatusOnlyCallContext) -> EventLoopFuture } extension B_ServiceBProvider { internal var serviceName: Substring { return "b.ServiceB" } /// Determines, calls and returns the appropriate request handler, depending on the request's method. /// Returns nil for methods not handled by this service. internal func handle( method name: Substring, context: CallHandlerContext ) -> GRPCServerHandlerProtocol? { switch name { case "CallServiceB": return UnaryServerHandler( context: context, requestDeserializer: ProtobufDeserializer(), responseSerializer: ProtobufSerializer(), interceptors: self.interceptors?.makeCallServiceBInterceptors() ?? [], userFunction: self.callServiceB(request:context:) ) default: return nil } } } internal protocol B_ServiceBServerInterceptorFactoryProtocol { /// - Returns: Interceptors to use when handling 'callServiceB'. /// Defaults to calling `self.makeInterceptors()`. func makeCallServiceBInterceptors() -> [ServerInterceptor] }