Home
last modified time | relevance | path

Searched refs:take_until (Results 1 – 25 of 39) sorted by relevance

12

/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dtake_until.cpp31 | 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/
Dtake_until.cpp10 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);
Dnever.cpp10 take_until(std::chrono::steady_clock::now() + std::chrono::milliseconds(10)).
/external/rust/crates/futures/tests/
Dstream.rs57 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/
Drx-take_until.hpp59 struct take_until : public operator_base<T> struct
79 take_until(source_type s, trigger_source_type t, coordination_type sf) in take_until() function
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/
DArrayRefTest.cpp159 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/
Dstr.rs106 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/
Dmain.cpp44 take_until(rx::observable<>::timer(std::chrono::seconds(1))). in main()
/external/llvm-project/lldb/source/Utility/
DTildeExpressionResolver.cpp85 Expr.take_until([](char c) { return path::is_separator(c); }); in ResolveFullPath()
/external/rust/crates/futures-util/src/stream/stream/
Dmod.rs144 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/
Dmacros.rs398 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"));
Dcomplete.rs409 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/
Dmain.cpp146 take_until(this->messages<WM_LBUTTONUP>()); in OnMovesWhileLButtonDown()
/external/swiftshader/third_party/llvm-subzero/include/llvm/ADT/
DArrayRef.h225 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/
DArrayRef.h240 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/
DArrayRef.h242 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
DStringRef.h635 StringRef take_until(function_ref<bool(char)> F) const { in take_until() function
/external/Reactive-Extensions/RxCpp/Rx/v2/test/
DCMakeLists.txt79 ${TEST_DIR}/operators/take_until.cpp
/external/Reactive-Extensions/RxCpp/projects/doxygen/
DCMakeLists.txt106 ${DOXY_EXAMPLES_SRC_DIR}/take_until.cpp
/external/llvm-project/flang/lib/Optimizer/Dialect/
DFIRAttr.cpp141 .take_until([](char c) { in parseFirRealAttr()
/external/llvm-project/clang/test/Analysis/
Dllvm-conventions.cpp122 StringRef take_until(function_ref<bool(char)> F) const;
/external/llvm-project/clang/lib/Tooling/Transformer/
DParsing.cpp185 StringRef Id = State.Input.take_until([](char c) { return c == '"'; }); in parseStringId()
/external/llvm-project/clang-tools-extra/clang-query/
DQueryParser.cpp44 Word = Line.take_until(isWhitespace); in lexWord()
/external/llvm-project/clang-tools-extra/clangd/
DFormat.cpp75 return Code.take_until([](char C) { return C == '\n'; }); in firstLine()
/external/llvm-project/clang-tools-extra/clangd/unittests/
DFindTargetTests.cpp43 llvm::StringRef(OS.str()).take_until([](char C) { return C == '\n'; }); in __anon925c2fef0202()

12