78 lines
		
	
	
	
		
			1.9 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			78 lines
		
	
	
	
		
			1.9 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| /*
 | |
| This file is part of Telegram Desktop,
 | |
| the official desktop application for the Telegram messaging service.
 | |
| 
 | |
| For license and copyright information please follow this link:
 | |
| https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
 | |
| */
 | |
| #include "base/observer.h"
 | |
| 
 | |
| namespace base {
 | |
| namespace internal {
 | |
| namespace {
 | |
| 
 | |
| bool CantUseObservables = false;
 | |
| 
 | |
| struct ObservableListWrap {
 | |
| 	~ObservableListWrap() {
 | |
| 		CantUseObservables = true;
 | |
| 	}
 | |
| 	OrderedSet<ObservableCallHandlers*> list;
 | |
| };
 | |
| 
 | |
| ObservableListWrap &PendingObservables() {
 | |
| 	static ObservableListWrap result;
 | |
| 	return result;
 | |
| }
 | |
| 
 | |
| ObservableListWrap &ActiveObservables() {
 | |
| 	static ObservableListWrap result;
 | |
| 	return result;
 | |
| }
 | |
| 
 | |
| } // namespace
 | |
| 
 | |
| void RegisterPendingObservable(ObservableCallHandlers *handlers) {
 | |
| 	if (CantUseObservables) return;
 | |
| 	PendingObservables().list.insert(handlers);
 | |
| 	Global::RefHandleObservables().call();
 | |
| }
 | |
| 
 | |
| void UnregisterActiveObservable(ObservableCallHandlers *handlers) {
 | |
| 	if (CantUseObservables) return;
 | |
| 	ActiveObservables().list.remove(handlers);
 | |
| }
 | |
| 
 | |
| void UnregisterObservable(ObservableCallHandlers *handlers) {
 | |
| 	if (CantUseObservables) return;
 | |
| 	PendingObservables().list.remove(handlers);
 | |
| 	ActiveObservables().list.remove(handlers);
 | |
| }
 | |
| 
 | |
| } // namespace internal
 | |
| 
 | |
| void HandleObservables() {
 | |
| 	if (internal::CantUseObservables) return;
 | |
| 	auto &active = internal::ActiveObservables().list;
 | |
| 	qSwap(active, internal::PendingObservables().list);
 | |
| 	while (!active.empty()) {
 | |
| 		auto first = *active.begin();
 | |
| 		(*first)();
 | |
| 		if (!active.empty() && *active.begin() == first) {
 | |
| 			active.erase(active.begin());
 | |
| 		}
 | |
| 	}
 | |
| }
 | |
| 
 | |
| rpl::producer<> ObservableViewer(base::Observable<void> &observable) {
 | |
| 	return [&observable](const auto &consumer) {
 | |
| 		auto lifetime = rpl::lifetime();
 | |
| 		lifetime.make_state<base::Subscription>(
 | |
| 			observable.add_subscription([consumer]() {
 | |
| 				consumer.put_next({});
 | |
| 			}));
 | |
| 		return lifetime;
 | |
| 	};
 | |
| }
 | |
| 
 | |
| } // namespace base
 | 
