Home
last modified time | relevance | path

Searched refs:send (Results 1 – 25 of 41) sorted by relevance

12

/unit/test/python/targets/
H A Dasgi.py1 async def application_201(scope, receive, send): argument
4 await send(
13 async def application_200(scope, receive, send): argument
16 await send(
25 async def application_prefix(scope, receive, send): argument
28 await send(
39 await send({'type': 'http.response.body', 'body': b''})
48 async def legacy_app_http_200(receive, send): argument
49 await send(
64 async def legacy_app_http_201(receive, send): argument
[all …]
/unit/test/python/lifespan/empty/
H A Dasgi.py4 async def handler(prefix, scope, receive, send): argument
14 await send({'type': 'lifespan.startup.complete'})
17 await send({'type': 'lifespan.shutdown.complete'})
21 await send(
32 async def application(scope, receive, send): argument
33 return await handler('', scope, receive, send)
36 async def application2(scope, receive, send): argument
37 return await handler('app2_', scope, receive, send)
/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
12 await send(
/unit/test/python/lifespan/failed/
H A Dasgi.py1 async def application(scope, receive, send): argument
6 await send({"type": "lifespan.startup.failed"})
10 await send({'type': 'lifespan.shutdown.complete'})
/unit/test/python/prefix/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
15 await send({'type': 'http.response.body', 'body': b''})
/unit/test/python/websockets/mirror/
H A Dasgi.py1 async def application(scope, receive, send): argument
6 await send({'type': 'websocket.accept'})
9 await send(
/unit/test/python/websockets/subprotocol/
H A Dasgi.py1 async def application(scope, receive, send): argument
9 await send(
20 await send(
/unit/test/python/mirror/
H A Dasgi.py1 async def application(scope, receive, send): argument
11 await send(
19 await send({'type': 'http.response.body', 'body': body})
/unit/test/python/204_no_content/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
/unit/test/python/empty/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
/unit/test/python/query_string/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
/unit/test/python/legacy/
H A Dasgi.py7 async def app_http(receive, send): argument
8 await send(
/unit/test/python/variables/
H A Dasgi.py1 async def application(scope, receive, send): argument
20 await send(
39 await send({'type': 'http.response.body', 'body': body})
/unit/test/python/server_port/
H A Dasgi.py1 async def application(scope, receive, send): argument
4 await send(
/unit/test/python/delayed/
H A Dasgi.py4 async def application(scope, receive, send): argument
32 await send(
46 await send(
/unit/test/python/threads/
H A Dasgi.py5 async def application(scope, receive, send): argument
20 await send(
/unit/test/node/websockets/mirror/
H A Dapp.js20 connection.send(message.utf8Data);
22 connection.send(message.binaryData);
/unit/test/python/threading/
H A Dasgi.py27 async def application(scope, receive, send): argument
33 await send(
/unit/test/node/loader/es_modules_websocket/
H A Dapp.mjs22 connection.send(message.utf8Data);
24 connection.send(message.binaryData);
/unit/test/node/loader/es_modules_websocket_indirect/
H A Dmodule.mjs22 connection.send(message.utf8Data);
24 connection.send(message.binaryData);
/unit/test/python/lifespan/error_auto/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/python/lifespan/error/
H A Dasgi.py1 async def application(scope, receive, send): argument
/unit/test/node/websockets/mirror_fragmentation/
H A Dapp.js17 connection.send(message.utf8Data);
/unit/src/python/
H A Dnxt_python_asgi_lifespan.c137 PyObject *scope, *res, *py_task, *receive, *send, *done; in nxt_py_asgi_lifespan_target_startup() local
161 send = PyObject_GetAttrString((PyObject *) lifespan, "send"); in nxt_py_asgi_lifespan_target_startup()
218 scope, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
248 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
311 Py_DECREF(send); in nxt_py_asgi_lifespan_target_startup()
H A Dnxt_python_asgi.c452 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
480 send = PyObject_GetAttrString(asgi, "send"); in nxt_py_asgi_request_handler()
481 if (nxt_slow_path(send == NULL)) { in nxt_py_asgi_request_handler()
536 scope, receive, send, NULL); in nxt_py_asgi_request_handler()
563 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_request_handler()
618 Py_DECREF(send); in nxt_py_asgi_request_handler()

12