Searched refs:OnCompleted (Results 1 – 13 of 13) sorted by relevance
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
D | rx-subscriber.hpp | 283 template<class T, class OnNext, class OnCompleted> 284 auto make_subscriber(const OnNext& on, const OnCompleted& oc) in make_subscriber() 287 detail::is_on_completed<OnCompleted>::value, in make_subscriber() 288 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber() 289 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(trace_id::mak… in make_subscriber() 290 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber() 292 template<class T, class OnNext, class OnError, class OnCompleted> 293 auto make_subscriber(const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber() 297 detail::is_on_completed<OnCompleted>::value, in make_subscriber() 298 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber() [all …]
|
D | rx-observer.hpp | 93 template<class State, class OnCompleted> 97 using oncompleted_t = rxu::decay_t<OnCompleted>; 178 template<class T, class State, class OnNext, class OnError, class OnCompleted> 182 using this_type = observer<T, State, OnNext, OnError, OnCompleted>; 193 !std::is_same<void, OnCompleted>::value, 194 rxu::decay_t<OnCompleted>, 195 detail::OnCompletedForward<State, OnCompleted>>::type; 269 template<class T, class OnNext, class OnError, class OnCompleted> 270 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted> : public observer_b… 273 using this_type = observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>; [all …]
|
D | rx-predef.hpp | 77 template<class T, class State = void, class OnNext = void, class OnError = void, class OnCompleted … 81 template<class T, class OnNext, class OnError, class OnCompleted> 82 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
D | grpc_client_cq_tag.h | 36 virtual void OnCompleted(bool ok) = 0;
|
D | grpc_worker_cache.cc | 114 callback_tag->OnCompleted(ok); in GrpcWorkerCacheThread()
|
D | grpc_state.h | 98 void OnCompleted(bool ok) override { in OnCompleted() function
|
D | grpc_call.h | 111 void OnCompleted(Service* service, bool ok) { in OnCompleted() function
|
D | grpc_rpc_factory.cc | 91 callback_tag->OnCompleted(ok); in GrpcRPCFactory()
|
D | grpc_master_service.cc | 126 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
|
D | grpc_worker_service.cc | 167 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
D | grpc_eager_service_impl.cc | 66 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
|
D | grpc_eager_client.cc | 113 callback_tag->OnCompleted(ok); in GrpcEagerClientThread()
|
/external/tensorflow/tensorflow/contrib/verbs/ |
D | grpc_verbs_service.cc | 93 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
|