Searched defs:future (Results 1 – 5 of 5) sorted by last modified time
| /unit/src/python/ |
| H A D | nxt_python_asgi.c | 1240 nxt_py_asgi_ctx_data_t *ctx_data, PyObject *future, PyObject *result) in nxt_py_asgi_set_result_soon()
|
| H A D | nxt_python_asgi_websocket.c | 139 PyObject *future, *msg; in nxt_py_asgi_websocket_receive() local
630 PyObject *future, *res; in nxt_py_asgi_websocket_receive_done() local
651 PyObject *future, *res; in nxt_py_asgi_websocket_receive_fail() local
1043 nxt_py_asgi_websocket_done(PyObject *self, PyObject *future) in nxt_py_asgi_websocket_done()
|
| H A D | nxt_python_asgi_http.c | 115 PyObject *msg, *future; in nxt_py_asgi_http_receive() local
361 PyObject *body, *more_body, *future; in nxt_py_asgi_http_response_body() local
470 PyObject *msg, *future; in nxt_py_asgi_http_emit_disconnect() local
496 nxt_py_asgi_http_set_result(nxt_py_asgi_http_t *http, PyObject *future, in nxt_py_asgi_http_set_result()
527 PyObject *msg, *future; in nxt_py_asgi_http_data_handler() local
562 PyObject *future, *exc, *res; in nxt_py_asgi_http_drain() local
648 nxt_py_asgi_http_done(PyObject *self, PyObject *future) in nxt_py_asgi_http_done()
|
| H A D | nxt_python_asgi_lifespan.c | 306 PyObject *msg, *future, *res; in nxt_py_asgi_lifespan_target_shutdown() local
363 PyObject *msg, *future; in nxt_py_asgi_lifespan_receive() local
493 PyObject *future, *res; in nxt_py_asgi_lifespan_send_() local
547 nxt_py_asgi_lifespan_done(PyObject *self, PyObject *future) in nxt_py_asgi_lifespan_done()
|
| /unit/src/java/nginx/unit/websocket/ |
| H A D | AsyncChannelWrapperSecure.java | 79 WrapperFuture<Integer,Void> future = new WrapperFuture<>(); in read() local
97 WrapperFuture<Integer,B> future = in read() local
125 Future<Integer> future = new LongToIntegerFuture(inner); in write() local
134 WrapperFuture<Long,B> future = in write() local
174 private final WrapperFuture<Long,?> future; field in AsyncChannelWrapperSecure.WriteTask
177 WrapperFuture<Long,?> future) { in WriteTask()
249 private final WrapperFuture<Integer,?> future; field in AsyncChannelWrapperSecure.ReadTask
251 public ReadTask(ByteBuffer dest, WrapperFuture<Integer,?> future) { in ReadTask()
|