Searched defs:take_until (Results 1 – 6 of 6) sorted by relevance
59 struct take_until : public operator_base<T> struct61 typedef rxu::decay_t<Observable> source_type;62 typedef rxu::decay_t<TriggerObservable> trigger_source_type;63 typedef rxu::decay_t<Coordination> coordination_type;64 typedef typename coordination_type::coordinator_type coordinator_type;65 struct values77 values initial;79 take_until(source_type s, trigger_source_type t, coordination_type sf) in take_until() argument84 struct mode96 void on_subscribe(Subscriber s) const { in on_subscribe()[all …]
233 template <class PredicateT> ArrayRef<T> take_until(PredicateT Pred) const { in take_until() function410 MutableArrayRef<T> take_until(PredicateT Pred) const { in take_until() function
637 StringRef take_until(function_ref<bool(char)> F) const { in take_until() function
225 template <class PredicateT> ArrayRef<T> take_until(PredicateT Pred) const { in take_until() function403 MutableArrayRef<T> take_until(PredicateT Pred) const { in take_until() function
626 StringRef take_until(function_ref<bool(char)> F) const { in take_until() function
1401 auto take_until(AN&&... an) const in take_until() function in rxcpp::observable