/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
D | take_until.cpp | 31 | rxo::take_until(ys) in __anonfd58ab610102() 93 .take_until(r) in __anonfd58ab610202() 156 .take_until(r) in __anonfd58ab610302() 217 .take_until(r) in __anonfd58ab610402() 279 .take_until(r) in __anonfd58ab610502() 338 .take_until(r) in __anonfd58ab610602() 394 .take_until(r) in __anonfd58ab610702() 448 .take_until(r) in __anonfd58ab610802() 499 .take_until(r) in __anonfd58ab610902() 554 .take_until(r) in __anonfd58ab610a02() [all …]
|
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
D | take_until.cpp | 10 auto values = source.take_until(trigger); 21 … auto values = source.take_until(std::chrono::steady_clock::now() + std::chrono::milliseconds(25)); 42 auto values = source.take_until(trigger, rxcpp::observe_on_new_thread()); 60 auto values = source.take_until(scheduler.now() + std::chrono::milliseconds(25), scheduler);
|
D | never.cpp | 10 take_until(std::chrono::steady_clock::now() + std::chrono::milliseconds(10)).
|
/external/rust/crates/futures/tests/ |
D | stream.rs | 57 fn take_until() { in take_until() function 79 let stream = stream.take_until(stop_fut); in take_until() 87 let mut stream = stream.take_until(stop_fut); in take_until() 100 let mut stream = stream.take_until(stop_fut); in take_until() 117 let mut stream = stream.take_until(stop_fut); in take_until()
|
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
D | rx-take_until.hpp | 59 struct take_until : public operator_base<T> struct 79 take_until(source_type s, trigger_source_type t, coordination_type sf) in take_until() argument 209 auto take_until(AN&&... an) in take_until() function 227 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable… 244 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable… 255 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig… 267 …class TakeUntil = rxo::detail::take_until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<Trig…
|
/external/llvm-project/llvm/unittests/ADT/ |
D | ArrayRefTest.cpp | 159 EXPECT_EQ(Expected, AR1.take_until([](const int &N) { return N % 2 == 0; })); in TEST() 161 EXPECT_EQ(AR1, AR1.take_until([](const int &N) { return N < 0; })); in TEST() 163 AR1.take_until([](const int &N) { return N > 0; })); in TEST()
|
/external/rust/crates/nom/src/ |
D | str.rs | 106 let res: IResult<_,_,(_, ErrorKind)> = take_until!(INPUT, FIND); in take_until_succeed() 367 let res: IResult<_,_,(_, ErrorKind)> = take_until!(INPUT, FIND); in take_until_incomplete() 449 let res: IResult<_,_,(_, ErrorKind)> = take_until!(INPUT, FIND); in take_until_error()
|
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/ |
D | main.cpp | 44 take_until(rx::observable<>::timer(std::chrono::seconds(1))). in main()
|
/external/llvm-project/lldb/source/Utility/ |
D | TildeExpressionResolver.cpp | 85 Expr.take_until([](char c) { return path::is_separator(c); }); in ResolveFullPath()
|
/external/rust/crates/futures-util/src/stream/stream/ |
D | mod.rs | 144 mod take_until; module 146 pub use self::take_until::TakeUntil; 827 fn take_until<Fut>(self, fut: Fut) -> TakeUntil<Self, Fut> in take_until() method
|
/external/rust/crates/nom/src/bytes/ |
D | macros.rs | 398 macro_rules! take_until ( macro 400 let res: $crate::IResult<_,_,_> = $crate::bytes::streaming::take_until($substr)($i); 684 named!(y, take_until!("end")); 692 named!(ys<&str, &str>, take_until!("end"));
|
D | complete.rs | 409 pub fn take_until<T, Input, Error: ParseError<Input>>(tag: T) -> impl Fn(Input) -> IResult<Input, I… in take_until() function
|
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/win_text/ |
D | main.cpp | 146 take_until(this->messages<WM_LBUTTONUP>()); in OnMovesWhileLButtonDown()
|
/external/swiftshader/third_party/llvm-subzero/include/llvm/ADT/ |
D | ArrayRef.h | 225 template <class PredicateT> ArrayRef<T> take_until(PredicateT Pred) const { in take_until() function 403 MutableArrayRef<T> take_until(PredicateT Pred) const { in take_until() function
|
/external/llvm-project/llvm/include/llvm/ADT/ |
D | ArrayRef.h | 240 template <class PredicateT> ArrayRef<T> take_until(PredicateT Pred) const { in take_until() function 417 MutableArrayRef<T> take_until(PredicateT Pred) const { in take_until() function
|
/external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/ADT/ |
D | ArrayRef.h | 242 template <class PredicateT> ArrayRef<T> take_until(PredicateT Pred) const { in take_until() function 419 MutableArrayRef<T> take_until(PredicateT Pred) const { in take_until() function
|
D | StringRef.h | 635 StringRef take_until(function_ref<bool(char)> F) const { in take_until() function
|
/external/Reactive-Extensions/RxCpp/Rx/v2/test/ |
D | CMakeLists.txt | 79 ${TEST_DIR}/operators/take_until.cpp
|
/external/Reactive-Extensions/RxCpp/projects/doxygen/ |
D | CMakeLists.txt | 106 ${DOXY_EXAMPLES_SRC_DIR}/take_until.cpp
|
/external/llvm-project/flang/lib/Optimizer/Dialect/ |
D | FIRAttr.cpp | 141 .take_until([](char c) { in parseFirRealAttr()
|
/external/llvm-project/clang/test/Analysis/ |
D | llvm-conventions.cpp | 122 StringRef take_until(function_ref<bool(char)> F) const;
|
/external/llvm-project/clang/lib/Tooling/Transformer/ |
D | Parsing.cpp | 185 StringRef Id = State.Input.take_until([](char c) { return c == '"'; }); in parseStringId()
|
/external/llvm-project/clang-tools-extra/clang-query/ |
D | QueryParser.cpp | 44 Word = Line.take_until(isWhitespace); in lexWord()
|
/external/llvm-project/clang-tools-extra/clangd/ |
D | Format.cpp | 75 return Code.take_until([](char C) { return C == '\n'; }); in firstLine()
|
/external/llvm-project/clang-tools-extra/clangd/unittests/ |
D | FindTargetTests.cpp | 43 llvm::StringRef(OS.str()).take_until([](char C) { return C == '\n'; }); in __anon925c2fef0202()
|