| 12345678910111213141516171819202122232425262728 |
- // unary
- public class {{ .|session:protoFile,service,method }} {
- var handler : gRPC.Handler
- var provider : {{ .|provider:protoFile,service }}
- fileprivate init(handler:gRPC.Handler, provider: {{ .|provider:protoFile,service }}) {
- self.handler = handler
- self.provider = provider
- }
- fileprivate func run(queue:DispatchQueue) {
- do {
- try handler.receiveMessage(initialMetadata:Metadata()) {(requestData) in
- if let requestData = requestData {
- let requestMessage = try! {{ method|input }}(protobuf:requestData)
- let replyMessage = try! self.provider.get(request:requestMessage)
- try self.handler.sendResponse(message:replyMessage.serializeProtobuf(),
- statusCode: 0,
- statusMessage: "OK",
- trailingMetadata:Metadata())
- }
- }
- } catch (let callError) {
- print("grpc error: \(callError)")
- }
- }
- }
|