Home
last modified time | relevance | path

Searched refs:receive (Results 1 – 20 of 20) sorted by last modified time

/unit/src/python/
H A Dnxt_python_asgi.c415 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
434 receive = PyObject_GetAttrString(asgi, "receive"); in nxt_py_asgi_request_handler()
435 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_request_handler()
443 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_request_handler()
451 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_request_handler()
472 scope, receive, send, NULL); in nxt_py_asgi_request_handler()
499 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_request_handler()
557 Py_DECREF(receive); in nxt_py_asgi_request_handler()
H A Dnxt_python_asgi_lifespan.c112 PyObject *scope, *res, *py_task, *receive, *send, *done; in nxt_py_asgi_lifespan_target_startup() local
130 receive = PyObject_GetAttrString((PyObject *) lifespan, "receive"); in nxt_py_asgi_lifespan_target_startup()
131 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_lifespan_target_startup()
137 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_lifespan_target_startup()
143 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_lifespan_target_startup()
176 scope, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
206 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
271 Py_DECREF(receive); in nxt_py_asgi_lifespan_target_startup()
/unit/test/python/204_no_content/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/python/threads/
H A Dasgi.py5 async def application(scope, receive, send): argument
/unit/test/python/threading/
H A Dasgi.py29 async def application(scope, receive, send): argument
/unit/test/python/lifespan/empty/
H A Dasgi.py4 async def handler(prefix, scope, receive, send): argument
11 message = await receive()
30 async def application(scope, receive, send): argument
31 return await handler('', scope, receive, send)
34 async def application2(scope, receive, send): argument
35 return await handler('app2_', scope, receive, send)
/unit/test/python/targets/
H A Dasgi.py1 async def application_201(scope, receive, send): argument
13 async def application_200(scope, receive, send): argument
31 async def legacy_app_http_200(receive, send): argument
41 def legacy_application_201(scope, receive=None, send=None): argument
47 async def legacy_app_http_201(receive, send): argument
/unit/test/python/websockets/mirror/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 m = await receive()
/unit/test/python/websockets/subprotocol/
H A Dasgi.py1 async def application(scope, receive, send): argument
5 m = await receive()
/unit/test/python/variables/
H A Dasgi.py1 async def application(scope, receive, send): argument
6 m = await receive()
/unit/test/python/query_string/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/python/server_port/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/python/legacy_force/
H A Dasgi.py1 def application(scope, receive=None, send=None): argument
4 if receive == None and send == None:
8 return app_http(receive, send)
11 async def app_http(receive, send): argument
/unit/test/python/mirror/
H A Dasgi.py1 async def application(scope, receive, send): argument
6 m = await receive()
/unit/test/python/legacy/
H A Dasgi.py7 async def app_http(receive, send): argument
/unit/test/python/delayed/
H A Dasgi.py4 async def application(scope, receive, send): argument
9 m = await receive()
/unit/test/python/empty/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/python/lifespan/failed/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 message = await receive()
/unit/test/python/lifespan/error/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/python/lifespan/error_auto/
H A Dasgi.py1 async def application(scope, receive, send): argument