(self, message, payload)
| 68 | super().connection_made(transport) |
| 69 | |
| 70 | def handle_request(self, message, payload): |
| 71 | if properties.get('close', False): |
| 72 | return |
| 73 | |
| 74 | for hdr, val in message.headers.items(): |
| 75 | if (hdr == 'EXPECT') and (val == '100-continue'): |
| 76 | self.transport.write(b'HTTP/1.0 100 Continue\r\n\r\n') |
| 77 | break |
| 78 | |
| 79 | if router is not None: |
| 80 | body = yield from payload.read() |
| 81 | |
| 82 | rob = router( |
| 83 | self, properties, self.transport, message, body) |
| 84 | rob.dispatch() |
| 85 | |
| 86 | else: |
| 87 | response = aiohttp.Response(self.writer, 200, message.version) |
| 88 | |
| 89 | text = b'Test message' |
| 90 | response.add_header('Content-type', 'text/plain') |
| 91 | response.add_header('Content-length', str(len(text))) |
| 92 | response.send_headers() |
| 93 | response.write(text) |
| 94 | response.write_eof() |
| 95 | |
| 96 | if use_ssl: |
| 97 | here = os.path.join(os.path.dirname(__file__), '..', 'tests') |
nothing calls this directly
no test coverage detected