| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-take.hpp | 42 struct take : public operator_base<T> struct
44 typedef rxu::decay_t<Observable> source_type;
45 typedef rxu::decay_t<Count> count_type;
46 struct values
56 values initial;
58 take(source_type s, count_type t) in take() argument
63 struct mode
74 void on_subscribe(const Subscriber& s) const { in on_subscribe()
133 auto take(AN&&... an) in take() function
|
| /external/okio/okio/src/commonMain/kotlin/okio/ |
| D | SegmentPool.kt | 32 fun take(): Segment method
|
| /external/llvm-project/clang/test/CodeGenCXX/ |
| D | pass-by-value-noalias.cpp | 19 void take(Foo arg) {} in take() function
43 void take(NonTrivial arg) {} in take() function
59 void take(A arg) {} in take() function
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | barrier_ops_test.py | 296 def take(): function
330 def take(sess, i, taken): function
537 def take(sess, i, taken): function
623 def take(sess, i, taken): function
|
| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ThrottlerTakeTest.kt | 110 private fun take(byteCount: Long): Long { in take() method
|
| /external/rust/crates/tokio/tests/ |
| D | io_take.rs | 8 async fn take() { in take() function
|
| /external/rust/crates/tinyvec/src/ |
| D | lib.rs | 112 fn take<T: Default>(from: &mut T) -> T { in take() function
|
| /external/okio/okio/src/nonJvmMain/kotlin/okio/ |
| D | SegmentPool.kt | 23 actual fun take(): Segment = Segment() in take() method
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | TestLogHandler.java | 41 public synchronized String take() throws InterruptedException { in take() method in TestLogHandler
|
| /external/llvm-project/clang/test/CXX/temp/temp.param/ |
| D | p15-cxx0x.cpp | 83 typedef types<typename Take<_>::type...> take; typedef
88 template<unsigned N, typename...Ts> struct take { struct
89 using type = typename takedrop_impl<typename make_places<N>::type>::
|
| /external/clang/test/CXX/temp/temp.param/ |
| D | p15-cxx0x.cpp | 83 typedef types<typename Take<_>::type...> take; typedef
88 template<unsigned N, typename...Ts> struct take { struct
89 using type = typename takedrop_impl<typename make_places<N>::type>::
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | ticket.h | 173 Ticket Ticket::Queue::take() { in take() function
180 void Ticket::Queue::take(size_t n, const F& f) { in take() function
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| D | SegmentPool.java | 36 static Segment take() { in take() method in SegmentPool
|
| /external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/ |
| D | SegmentPool.java | 37 static Segment take() { in take() method in SegmentPool
|
| /external/rust/crates/bytes/src/buf/ |
| D | mod.rs | 26 mod take; module
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | PoolService.java | 48 Future<FutureType> take = m_completionService.take(); in submitTasksAndWait() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/ |
| D | ThreadContext.kt | 19 fun take() = a[i++] in take() method
|
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| D | IntQueue.java | 46 int take() { in take() method in IntQueue
|
| /external/llvm-project/clang/test/CodeGen/ |
| D | pass-by-value-noalias.c | 16 void take(struct Foo arg) {} in take() function
|
| /external/llvm-project/clang/include/clang/Basic/ |
| D | DiagnosticError.h | 39 static Optional<PartialDiagnosticAt> take(llvm::Error &Err) { in take() function
|
| /external/llvm-project/clang/test/CodeGenObjC/ |
| D | pass-by-value-noalias.m | 22 void take(struct Foo arg) {} function
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/ |
| D | scan_test.py | 57 def dataset_fn(start, step, take): argument
95 def dataset_fn(start, step, take): argument
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingBlockingQueue.java | 80 public E take() throws InterruptedException { in take() method in ForwardingBlockingQueue
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 35 CompletionQueue::CompletionQueue(grpc_completion_queue* take) in CompletionQueue()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingBlockingQueue.java | 80 public E take() throws InterruptedException { in take() method in ForwardingBlockingQueue
|