Home
last modified time | relevance | path

Searched refs:PendingRequests (Results 1 – 10 of 10) sorted by relevance

/aosp_15_r20/external/rust/android-crates-io/crates/tower/src/load/
Dpending_requests.rs20 pub struct PendingRequests<S, C = CompleteOnResponse> { struct
52 impl<S, C> PendingRequests<S, C> { implementation
67 impl<S, C> Load for PendingRequests<S, C> { implementation
76 impl<S, C, Request> Service<Request> for PendingRequests<S, C> implementation
122 type Item = Result<Change<D::Key, PendingRequests<D::Service, C>>, D::Error>;
131 Some(Insert(k, svc)) => Insert(k, PendingRequests::new(svc, this.completion.clone())), in poll_next()
170 let mut svc = PendingRequests::new(Svc, CompleteOnResponse); in default()
197 let mut svc = PendingRequests::new(Svc, IntoHandle); in with_completion()
Dmod.rs71 pending_requests::PendingRequests,
/aosp_15_r20/external/openscreen/cast/sender/
H A Dcast_platform_client.cc65 PendingRequests& pending_requests = in RequestAppAvailability()
158 PendingRequests& pending_requests = entry->second; in HandleResponse()
192 PendingRequests& pending_requests = entry.second; in CancelAppAvailabilityRequest()
H A Dcast_platform_client.h64 struct PendingRequests { struct
86 std::map<std::string /* receiver_id */, PendingRequests> argument
/aosp_15_r20/external/cronet/net/proxy_resolution/win/
H A Dwindows_system_proxy_resolution_service.h74 PendingRequests; typedef
97 PendingRequests pending_requests_;
/aosp_15_r20/external/openthread/src/core/net/
H A Ddns_dso.cpp1370 bool Dso::Connection::PendingRequests::Contains(MessageId aMessageId, Tlv::Type &aPrimaryTlvType) c… in Contains()
1382 Error Dso::Connection::PendingRequests::Add(MessageId aMessageId, Tlv::Type aPrimaryTlvType, TimeMi… in Add()
1396 void Dso::Connection::PendingRequests::Remove(MessageId aMessageId) { mRequests.RemoveMatching(aMes… in Remove()
1398 bool Dso::Connection::PendingRequests::HasAnyTimedOut(TimeMilli aNow) const in HasAnyTimedOut()
1414 void Dso::Connection::PendingRequests::UpdateNextFireTime(NextFireTime &aNextTime) const in UpdateNextFireTime()
H A Ddns_dso.hpp713 class PendingRequests class in ot::Dns::Dso::Connection
825 PendingRequests mPendingRequests;
/aosp_15_r20/external/cronet/net/proxy_resolution/
H A Dconfigured_proxy_resolution_service.h256 PendingRequests; typedef
366 PendingRequests pending_requests_;
/aosp_15_r20/external/cronet/net/socket/
H A Dtransport_client_socket_pool_unittest.cc620 TEST_F(TransportClientSocketPoolTest, PendingRequests) { in TEST_F() argument
H A Dclient_socket_pool_base_unittest.cc1487 TEST_F(ClientSocketPoolBaseTest, PendingRequests) { in TEST_F() argument