403a404,444 > > def test_asgi_application_threads(self): > self.load('threads') > > assert 'success' in self.conf( > '4', 'applications/threads/threads' > ), 'configure 4 threads' > > socks = [] > > for i in range(4): > (_, sock) = self.get( > headers={ > 'Host': 'localhost', > 'X-Delay': '2', > 'Connection': 'close', > }, > no_recv=True, > start=True, > ) > > socks.append(sock) > > time.sleep(0.25) # required to avoid greedy request reading > > threads = set() > > for sock in socks: > resp = self.recvall(sock).decode('utf-8') > > self.log_in(resp) > > resp = self._resp_to_dict(resp) > > assert resp['status'] == 200, 'status' > > threads.add(resp['headers']['x-thread']) > > sock.close() > > assert len(socks) == len(threads), 'threads differs'