server-session-unary.swift 1.5 KB

12345678910111213141516171819202122232425262728293031
  1. // {{ method|methodDescriptorName }} (Unary Streaming)
  2. {{ access }} protocol {{ .|session:file,service,method }} : {{ .|service:file,service }}Session { }
  3. fileprivate final class {{ .|session:file,service,method }}Impl : {{ .|service:file,service }}SessionImpl, {{ .|session:file,service,method }} {
  4. private var provider : {{ .|provider:file,service }}
  5. /// Create a session.
  6. init(handler:Handler, provider: {{ .|provider:file,service }}) {
  7. self.provider = provider
  8. super.init(handler:handler)
  9. }
  10. /// Run the session. Internal.
  11. func run(queue:DispatchQueue) throws {
  12. try handler.receiveMessage(initialMetadata:initialMetadata) {(requestData) in
  13. if let requestData = requestData {
  14. let requestMessage = try {{ method|input }}(serializedData:requestData)
  15. let replyMessage = try self.provider.{{ method|methodDescriptorName|lowercase }}(request:requestMessage, session: self)
  16. try self.handler.sendResponse(message:replyMessage.serializedData(),
  17. statusCode:self.statusCode,
  18. statusMessage:self.statusMessage,
  19. trailingMetadata:self.trailingMetadata)
  20. }
  21. }
  22. }
  23. }
  24. //-{% if generateTestStubs %}
  25. /// Trivial fake implementation of {{ .|session:file,service,method }}.
  26. class {{ .|session:file,service,method }}TestStub : {{ .|service:file,service }}SessionTestStub, {{ .|session:file,service,method }} { }
  27. //-{% endif %}