Searched refs:rxn (Results 1 – 13 of 13) sorted by relevance
153 …rxt::testable_observable<T> make_hot_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::det…156 …rxt::testable_observable<T> make_cold_observable(std::vector<rxn::recorded<std::shared_ptr<rxn::de…163 typedef typename rxn::notification<T> notification_type;164 typedef rxn::recorded<typename notification_type::type> recorded_type;178 virtual std::vector<rxn::subscription> subscriptions() const { in subscriptions()190 typedef typename rxn::notification<T> notification_type; in make_subscriber()191 typedef rxn::recorded<typename notification_type::type> recorded_type; in make_subscriber()222 typedef rxn::recorded<typename rxn::notification<T>::type> recorded_type;224 mutable std::vector<rxn::subscription> sv;245 sv.push_back(rxn::subscription(sc->clock())); in on_subscribe()[all …]
18 typedef rxn::recorded<typename rxn::notification<T>::type> recorded_type;24 virtual std::vector<rxn::subscription> subscriptions() const =0;101 std::vector<rxn::subscription> subscriptions() const { in subscriptions()
269 namespace rxn=notifications;
49 auto required = std::vector<rxn::subscription>();153 auto required = std::vector<rxn::subscription>();207 auto required = std::vector<rxn::subscription>();
195 auto required = std::vector<rxn::subscription>();
677 auto required = std::vector<rxn::subscription>();
17 namespace rxn=rx::notifications; variable
41 …rxn�syo�rxm�oul�nsm�nsm�lqk�joi�kpk�ksk�jtl�mul�w�u�y�t�s~l�~�t���������ktm�@@@�@@@�@@@�@@@�@@@�@@…
89 …vj��xl���s��}w��y���{��x��}v��yt��zs��}r��~r��{k���y���}��������r�k�rwo�rxn�syo�rxm�oul�nsm�nsm…90 …/ � � �����u��~f���l���n���t���q���r�����z�j�wd���e�������~���o�tyo�txo�rxn�syo�szr�u{u�txs�tzt…
43 ǿ��������������������������v��vo�rxn�x|s��sw��vv����������Ф��ީ����������������ӱ��������������������…
28 typedef rxn::notification<T> notification_type;
67 typedef rxn::notification<T> notification_type;
607 chemical/x-mdl-rxnfile rxn