server-session-unary.swift 1011 B

12345678910111213141516171819202122232425
  1. // {{ method.name }} (Unary)
  2. public class {{ .|session:protoFile,service,method }} {
  3. private var handler : gRPC.Handler
  4. private var provider : {{ .|provider:protoFile,service }}
  5. /// Create a session.
  6. fileprivate init(handler:gRPC.Handler, provider: {{ .|provider:protoFile,service }}) {
  7. self.handler = handler
  8. self.provider = provider
  9. }
  10. /// Run the session. Internal.
  11. fileprivate func run(queue:DispatchQueue) throws {
  12. try handler.receiveMessage(initialMetadata:Metadata()) {(requestData) in
  13. if let requestData = requestData {
  14. let requestMessage = try {{ method|input }}(protobuf:requestData)
  15. let replyMessage = try self.provider.{{ method.name|lowercase }}(request:requestMessage)
  16. try self.handler.sendResponse(message:replyMessage.serializeProtobuf(),
  17. statusCode: 0,
  18. statusMessage: "OK",
  19. trailingMetadata:Metadata())
  20. }
  21. }
  22. }
  23. }