| 12345678910111213141516171819202122232425 |
- // {{ method.name }} (Unary)
- public class {{ .|session:protoFile,service,method }} {
- private var handler : gRPC.Handler
- private var provider : {{ .|provider:protoFile,service }}
- /// Create a session.
- fileprivate init(handler:gRPC.Handler, provider: {{ .|provider:protoFile,service }}) {
- self.handler = handler
- self.provider = provider
- }
- /// Run the session. Internal.
- fileprivate func run(queue:DispatchQueue) throws {
- try handler.receiveMessage(initialMetadata:Metadata()) {(requestData) in
- if let requestData = requestData {
- let requestMessage = try {{ method|input }}(protobuf:requestData)
- let replyMessage = try self.provider.{{ method.name|lowercase }}(request:requestMessage)
- try self.handler.sendResponse(message:replyMessage.serializeProtobuf(),
- statusCode: 0,
- statusMessage: "OK",
- trailingMetadata:Metadata())
- }
- }
- }
- }
|