Home
last modified time | relevance | path

Searched refs:on_response (Results 1 – 25 of 540) sorted by relevance

12345678910>>...22

/dports/devel/py-azure-core/azure-core-1.20.1/tests/
H A Dtest_universal_pipeline.py125 http_logger.on_response(request, response)
135 http_logger.on_response(request, response)
144 http_logger.on_response(request, response)
153 http_logger.on_response(request, response)
163 http_logger.on_response(request, response)
170 http_logger.on_response(request, response)
176 http_logger.on_response(request, response)
235 raw_deserializer.on_response(request, response)
240 raw_deserializer.on_response(request, response)
246 raw_deserializer.on_response(request, response)
[all …]
H A Dtest_http_logging_policy.py52 policy.on_response(request, response)
71 policy.on_response(request, response)
75 policy.on_response(request, response)
114 policy.on_response(request, response)
176 policy.on_response(request, response)
197 policy.on_response(request, response)
201 policy.on_response(request, response)
252 policy.on_response(request, response)
297 policy.on_response(request, response)
H A Dtest_tracing_policy.py42 … policy.on_response(pipeline_request, PipelineResponse(request, response, PipelineContext(None)))
91 … policy.on_response(pipeline_request, PipelineResponse(request, response, PipelineContext(None)))
120 … policy.on_response(pipeline_request, PipelineResponse(request, response, PipelineContext(None)))
157 policy.on_response(pipeline_request, pipeline_response)
166 user_agent.on_response(pipeline_request, pipeline_response)
211 … policy.on_response(pipeline_request, PipelineResponse(request, response, PipelineContext(None)))
225 … policy.on_response(pipeline_request, PipelineResponse(request, response, PipelineContext(None)))
/dports/net-mgmt/py-msrest/msrest-0.6.21/tests/
H A Dtest_universal_pipeline.py74 http_logger.on_response(request, response)
96 http_logger.on_response(request, response)
126 raw_deserializer.on_response(None, response, stream=False)
136 raw_deserializer.on_response(None, response, stream=False)
143 raw_deserializer.on_response(None, response, stream=False)
146 raw_deserializer.on_response(None, response, stream=False)
150 raw_deserializer.on_response(None, response, stream=False)
156 raw_deserializer.on_response(None, response, stream=False)
162 raw_deserializer.on_response(None, response, stream=False)
168 raw_deserializer.on_response(None, response, stream=False)
[all …]
/dports/devel/py-taskflow/taskflow-4.6.3/taskflow/tests/unit/worker_based/
H A Dtest_message_pump.py63 on_response = mock.MagicMock()
64 on_response.side_effect = lambda *args, **kwargs: barrier.set()
66 handlers = {pr.RESPONSE: dispatcher.Handler(on_response)}
84 self.assertTrue(on_response.called)
85 on_response.assert_called_with(resp.to_dict(), mock.ANY)
95 on_response = mock.MagicMock()
96 on_response.side_effect = countdown
103 pr.RESPONSE: dispatcher.Handler(on_response),
133 self.assertTrue(on_response.called)
137 self.assertEqual(10, on_response.call_count)
[all …]
/dports/www/p5-HTTP-WebTest/HTTP-WebTest-2.04/t/
H A D09-hooks.t53 on_response => sub { $counter_value = counter(); [] } }
63 on_response => sub { inc_counter(); [] } } ];
72 on_response => [ 'yes', 'Test 1' ] },
74 on_response => [ 'no', 'Test 2' ] },
76 on_response => [ 'yes', 'Test 3',
79 on_response => [] } ];
/dports/devel/py-azure-appconfiguration/azure-appconfiguration-1.1.1/tests/
H A Dtest_sync_token_policy.py26 sync_token_policy.on_response(None, pipeline_response)
41 sync_token_policy.on_response(None, pipeline_response)
54 sync_token_policy.on_response(None, pipeline_response)
73 sync_token_policy.on_response(None, pipeline_response)
87 sync_token_policy.on_response(None, pipeline_response)
96 sync_token_policy.on_response(None, pipeline_response)
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/attestation/
H A Dattestation_ca_client.h32 DataCallback on_response) override;
34 DataCallback on_response) override;
38 DataCallback on_response,
50 DataCallback on_response);
H A Dattestation_ca_client.cc66 DataCallback on_response) { in SendEnrollRequest() argument
69 request, std::move(on_response)); in SendEnrollRequest()
73 DataCallback on_response) { in SendCertificateRequest() argument
76 request, std::move(on_response)); in SendCertificateRequest()
114 DataCallback on_response) { in FetchURL() argument
160 std::move(on_response))); in FetchURL()
/dports/www/nginx-full/nchan-1.2.12/dev/nchan_tools-gem/exe/
H A Dnchan-pub12 on_response=Proc.new {}
41 on_response = Proc.new do |code, body|
74 pub.submit msg, method, content_type, eventsource_event, &on_response
78 pub.submit this_msg, method, content_type, eventsource_event, &on_response
91 pub.submit message, method, content_type, eventsource_event, &on_response
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/extensions/renderer/
H A Dwake_event_page.h75 RequestData(int thread_id, const OnResponseCallback& on_response);
83 OnResponseCallback on_response; member
87 static void RunOnResponseWithResult(const OnResponseCallback& on_response,
93 const OnResponseCallback& on_response);
H A Dwake_event_page.cc153 const OnResponseCallback& on_response) in RequestData() argument
154 : thread_id(thread_id), on_response(on_response) {} in RequestData()
163 const OnResponseCallback& on_response) { in MakeRequest() argument
169 content::WorkerThread::GetCurrentId(), on_response); in MakeRequest()
197 request_data->on_response.Run(success); in OnWakeEventPageResponse()
201 base::Bind(request_data->on_response, success)); in OnWakeEventPageResponse()
/dports/www/chromium-legacy/chromium-88.0.4324.182/extensions/renderer/
H A Dwake_event_page.h75 RequestData(int thread_id, const OnResponseCallback& on_response);
83 OnResponseCallback on_response; member
87 static void RunOnResponseWithResult(const OnResponseCallback& on_response,
93 const OnResponseCallback& on_response);
H A Dwake_event_page.cc153 const OnResponseCallback& on_response) in RequestData() argument
154 : thread_id(thread_id), on_response(on_response) {} in RequestData()
163 const OnResponseCallback& on_response) { in MakeRequest() argument
169 content::WorkerThread::GetCurrentId(), on_response); in MakeRequest()
197 request_data->on_response.Run(success); in OnWakeEventPageResponse()
201 base::BindOnce(request_data->on_response, success)); in OnWakeEventPageResponse()
/dports/devel/py-azure-core/azure-core-1.20.1/tests/async_tests/
H A Dtest_http_logging_policy_async.py50 policy.on_response(request, response)
69 policy.on_response(request, response)
73 policy.on_response(request, response)
112 policy.on_response(request, response)
173 policy.on_response(request, response)
194 policy.on_response(request, response)
198 policy.on_response(request, response)
248 policy.on_response(request, response)
294 policy.on_response(request, response)
/dports/security/vaultwarden/Rocket-263e39b5b429de1913ce7e3036575a7b4d88b6d7/core/lib/src/fairing/
H A Dmod.rs411 fn on_response(&self, request: &Request<'_>, response: &mut Response<'_>) {} in on_response() method
436 fn on_response(&self, request: &Request<'_>, response: &mut Response<'_>) { in on_response() method
437 (self as &T).on_response(request, response) in on_response()
/dports/www/p5-Net-Async-HTTP/Net-Async-HTTP-0.48/t/
H A D30timeout.t46 on_response => sub { die "Test died early - got a response but shouldn't have" },
73 on_response => sub { die "Test died early - got a response but shouldn't have" },
107 on_response => sub { die "Test died early - got a response but shouldn't have" },
119 on_response => sub { die "Test died early - got a response but shouldn't have" },
/dports/net/py-socketio-client/socketIO_client-0.6.7/socketIO_client/tests/
H A D__init__.py64 self.socketIO.emit('emit_with_callback', self.on_response)
71 'emit_with_callback_with_payload', self.on_response)
78 'emit_with_callback_with_multiple_payloads', self.on_response)
84 self.socketIO.on('emit_with_event_response', self.on_response)
98 self.socketIO.once('emit_with_event_response', self.on_response)
160 def on_response(self, *args): member in BaseMixin
/dports/x11/lxpanel/lxpanel-0.9.3/plugins/netstatus/
H A Dnetstatus.c43 static void on_response( GtkDialog* dlg, gint response, netstatus *ns );
58 g_signal_handlers_disconnect_by_func(ns->dlg, on_response, ns); in netstatus_destructor()
65 static void on_response( GtkDialog* dlg, gint response, netstatus *ns ) in on_response() function
100 g_signal_connect( ns->dlg, "response", G_CALLBACK(on_response), ns ); in on_button_press()
/dports/audio/ardour6/Ardour-6.8.0/gtk2_ardour/
H A Dardour_dialog.cc69 ArdourDialog::on_response (int response_id) in on_response() function in ArdourDialog
74 Gtk::Dialog::on_response (response_id); in on_response()
85 Gtk::Dialog::on_response (RESPONSE_CANCEL); in close_self()
H A Dnormalize_dialog.h40 void on_response (int response_id) { in on_response() function
41 Gtk::Dialog::on_response (response_id); in on_response()
/dports/net/measurement-kit/measurement-kit-0.10.14/test/http/
H A Dresponse_parser.cpp65 parser.on_response([](Response r) { in __anon16bd779d0102()
99 parser.on_response([](Response r) { in __anon16bd779d0402()
140 parser.on_response([](Response r) { in __anon16bd779d0702()
176 parser.on_response([](Response) { in __anon16bd779d0a02()
/dports/net/pjsip/pjproject-2.11.1/pjlib-util/src/pjlib-util-test/
H A Dhttp_client.c212 static void on_response(pj_http_req *hreq, const pj_http_resp *resp) in on_response() function
391 hcb.on_response = &on_response; in http_client_test1()
499 hcb.on_response = &on_response; in http_client_test2()
634 hcb.on_response = &on_response; in http_client_test_put1()
737 hcb.on_response = &on_response; in http_client_test_put2()
832 hcb.on_response = &on_response; in http_client_test_delete()
/dports/www/nginx-full/nchan-1.2.12/dev/
H A Dpub-multi.rb10 on_response=Proc.new {}
35 p.last.submit this_msg, method, content_type, &on_response
/dports/devel/py-azure-core/azure-core-1.20.1/azure/core/pipeline/policies/
H A D_authentication_async.py76 await await_result(self.on_response, request, response)
89 await await_result(self.on_response, request, response)
109 …def on_response(self, request: "PipelineRequest", response: "PipelineResponse") -> "Union[None, Aw… member in AsyncBearerTokenCredentialPolicy

12345678910>>...22