| 109 | |
| 110 | |
| 111 | class GeneratorCapClient(BaseCapClient): |
| 112 | @gen.coroutine |
| 113 | def capitalize(self, request_data): |
| 114 | logging.debug("capitalize") |
| 115 | stream = IOStream(socket.socket()) |
| 116 | logging.debug("connecting") |
| 117 | yield stream.connect(("127.0.0.1", self.port)) |
| 118 | stream.write(utf8(request_data + "\n")) |
| 119 | logging.debug("reading") |
| 120 | data = yield stream.read_until(b"\n") |
| 121 | logging.debug("returning") |
| 122 | stream.close() |
| 123 | raise gen.Return(self.process_response(data)) |
| 124 | |
| 125 | |
| 126 | class GeneratorCapClientTest(AsyncTestCase): |