Home
last modified time | relevance | path

Searched refs:OnCompleted (Results 1 – 15 of 15) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscriber.hpp283 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 …]
Drx-observer.hpp93 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 …]
Drx-predef.hpp77 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/v8/src/execution/
Dmicrotask-queue.cc144 OnCompleted(isolate); in RunMicrotasks()
183 OnCompleted(isolate); in RunMicrotasks()
187 OnCompleted(isolate); in RunMicrotasks()
256 void MicrotaskQueue::OnCompleted(Isolate* isolate) { in OnCompleted() function in v8::internal::MicrotaskQueue
Dmicrotask-queue.h110 void OnCompleted(Isolate* isolate);
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_client_cq_tag.h35 virtual void OnCompleted(bool ok) = 0;
Dgrpc_call.h83 virtual void OnCompleted(Service* service, bool ok) = 0;
123 void OnCompleted(Service* service, bool ok) override { in OnCompleted() function
328 void OnCompleted(Service* service, bool ok) override { in OnCompleted() function
Dgrpc_worker_cache.cc147 callback_tag->OnCompleted(ok); in GrpcWorkerCacheThread()
Dgrpc_state.h115 void OnCompleted(bool ok) override { in OnCompleted() function
232 void OnCompleted(bool ok) override;
Dgrpc_rpc_factory.cc91 callback_tag->OnCompleted(ok); in GrpcRPCFactory()
Dgrpc_state.cc38 void UntypedStreamingRPCState::Tag::OnCompleted(bool ok) { in OnCompleted() function in tensorflow::UntypedStreamingRPCState::Tag
Dgrpc_master_service.cc126 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
Dgrpc_worker_service.cc168 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc79 callback_tag->OnCompleted(this, ok); in HandleRPCsLoop()
Dgrpc_eager_client.cc83 callback_tag->OnCompleted(ok); in GrpcEagerClientThread()