Searched refs:client_stream (Results 1 – 7 of 7) sorted by relevance
| /third_party/node/test/parallel/ |
| D | test-http2-cancel-while-client-reading.js | 14 let client_stream; variable
20 client_stream.pause();
21 client_stream.close(http2.constants.NGHTTP2_CANCEL);
29 client_stream = client.request({ ':method': 'POST' });
30 client_stream.on('close', common.mustCall(() => {
34 client_stream.resume();
35 client_stream.write(Buffer.alloc(1024 * 1024));
|
| D | test-http2-close-while-writing.js | 22 let client_stream; variable
29 process.nextTick(() => client_stream.destroy());
39 client_stream = client.request({ ':method': 'POST' });
40 client_stream.on('close', common.mustCall(() => {
44 client_stream.resume();
45 client_stream.write(Buffer.alloc(64 * 1024));
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 138 grpc_chttp2_stream* client_stream = in Log() local
160 client_stream ? client_stream->flow_control->remote_window_delta_ : -1, in Log()
162 client_stream ? client_stream->flow_control->local_window_delta_ : -1, in Log()
164 client_stream ? client_stream->flow_control->announced_window_delta_ in Log()
184 client_stream ? client_stream->flow_controlled_buffer.length : 0, in Log()
|
| /third_party/glib/gio/tests/ |
| D | gdbus-connection-flush.c | 161 GIOStream *client_stream; member
225 f->client_stream = test_io_stream_new (f->client_istream, f->client_ostream); in setup()
228 g_dbus_connection_new (f->client_stream, NULL, in setup()
349 g_clear_object (&f->client_stream); in teardown()
|
| D | socket.c | 1822 GSocketConnection *server_stream, *client_stream; in test_read_write() local
1869 client_stream = g_socket_connection_factory_create_connection (client); in test_read_write()
1870 g_assert_nonnull (client_stream); in test_read_write()
1876 data.os = g_io_stream_get_output_stream (G_IO_STREAM (client_stream)); in test_read_write()
1895 g_object_unref (client_stream); in test_read_write()
|
| /third_party/libsoup/libsoup/ |
| D | soup-message-io.c | 1138 GInputStream *client_stream; in soup_message_io_get_response_istream() local
1148 client_stream = soup_client_input_stream_new (io->body_istream, msg); in soup_message_io_get_response_istream()
1149 g_signal_connect (client_stream, "eof", in soup_message_io_get_response_istream()
1152 return client_stream; in soup_message_io_get_response_istream()
|
| D | soup-cache.c | 674 GInputStream *file_stream, *body_stream, *cache_stream, *client_stream; in soup_cache_send_response() local
717 client_stream = soup_cache_client_input_stream_new (cache_stream); in soup_cache_send_response()
720 return client_stream; in soup_cache_send_response()
|