| /external/grpc-grpc/src/python/grpcio/grpc/framework/foundation/ |
| stream.py | 21 class Consumer(six.with_metaclass(abc.ABCMeta)):
29 value: Any value accepted by this Consumer.
35 """Indicates to this Consumer that no more values will be supplied."""
43 value: Any value accepted by this Consumer.
|
| /external/perfetto/include/perfetto/tracing/core/ |
| consumer.h | 32 class PERFETTO_EXPORT Consumer {
34 virtual ~Consumer();
37 // the remote Service), once the Consumer <> Service connection has been
49 // - The consumer explicitly called DisableTracing()
64 // The consumer can disconnect at this point and the trace session will keep
65 // on going. A new consumer can later re-attach passing back the same |key|
|
| /dalvik/dx/tests/139-lambda-metafactory/ |
| Consumer.class | |
| Main.java | 17 interface Consumer<T> {
24 Consumer consumer = k -> System.out.println(((i + j) + (int)k)); local
25 consumer.accept(1);
|
| /external/clang/unittests/AST/ |
| EvaluateAsRValueTest.cpp | 63 return llvm::make_unique<Consumer>();
67 class Consumer : public clang::ASTConsumer {
69 ~Consumer() override {}
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| TsiFrameProtector.java | 40 List<ByteBuf> unprotectedBufs, Consumer<ByteBuf> ctxWrite, ByteBufAllocator alloc)
56 /** A mirror of java.util.function.Consumer without the Java 8 dependency. */
57 interface Consumer<T> {
|
| /external/robolectric-shadows/utils/src/main/java/org/robolectric/util/ |
| Consumer.java | 7 * result. Unlike most other functional interfaces, {@code Consumer} is expected
14 public interface Consumer<T> {
24 * Returns a composed {@code Consumer} that performs, in sequence, this operation followed by the
30 * @return a composed {@code Consumer} that performs in sequence this operation followed by the
34 default Consumer<T> andThen(Consumer<? super T> after) {
|
| /external/llvm/tools/llvm-diff/ |
| DiffConsumer.h | 1 //===-- DiffConsumer.h - Difference Consumer --------------------*- C++ -*-===//
10 // This header defines the interface to the LLVM difference Consumer
31 class Consumer {
53 virtual ~Consumer() {}
56 class DiffConsumer : public Consumer {
|
| /external/swiftshader/third_party/LLVM/tools/llvm-diff/ |
| DiffConsumer.h | 1 //===-- DiffConsumer.h - Difference Consumer --------------------*- C++ -*-===//
10 // This header defines the interface to the LLVM difference Consumer
31 class Consumer {
52 virtual ~Consumer() {}
55 class DiffConsumer : public Consumer {
|
| /external/swiftshader/third_party/llvm-7.0/llvm/tools/llvm-diff/ |
| DiffConsumer.h | 1 //===-- DiffConsumer.h - Difference Consumer --------------------*- C++ -*-===//
10 // This header defines the interface to the LLVM difference Consumer
31 class Consumer {
53 virtual ~Consumer() {}
56 class DiffConsumer : public Consumer {
|
| /device/linaro/bootloader/edk2/OvmfPkg/Library/XenConsoleSerialPortLib/ |
| XenConsoleSerialPortLib.c | 105 XENCONS_RING_IDX Consumer, Producer;
120 Consumer = mXenConsoleInterface->out_cons;
125 while (Sent < NumberOfBytes && ((Producer - Consumer) < sizeof (mXenConsoleInterface->out)))
161 XENCONS_RING_IDX Consumer, Producer;
174 Consumer = mXenConsoleInterface->in_cons;
180 while (Received < NumberOfBytes && Consumer < Producer)
181 Buffer[Received++] = mXenConsoleInterface->in[MASK_XENCONS_IDX(Consumer++, mXenConsoleInterface->in)];
185 mXenConsoleInterface->in_cons = Consumer;
|
| /external/clang/lib/Parse/ |
| ParseAST.cpp | 98 void clang::ParseAST(Preprocessor &PP, ASTConsumer *Consumer,
105 new Sema(PP, Ctx, *Consumer, TUKind, CompletionConsumer));
124 ASTConsumer *Consumer = &S.getASTConsumer();
148 External->StartTranslationUnit(Consumer);
158 if (ADecl && !Consumer->HandleTopLevelDecl(ADecl.get()))
165 Consumer->HandleTopLevelDecl(DeclGroupRef(D));
167 Consumer->HandleTranslationUnit(S.getASTContext());
176 Consumer->PrintStats();
|
| RAIIObjectsForParser.h | 368 SourceLocation (Parser::*Consumer)();
395 Consumer = &Parser::ConsumeBrace;
399 Consumer = &Parser::ConsumeParen;
404 Consumer = &Parser::ConsumeBracket;
418 LOpen = (P.*Consumer)();
430 LClose = (P.*Consumer)();
436 LClose = (P.*Consumer)();
|
| /external/libchrome/ipc/ |
| ipc_logging.h | 41 class Consumer {
46 virtual ~Consumer() {}
49 void SetConsumer(Consumer* consumer);
119 Consumer* consumer_;
|
| /external/tensorflow/tensorflow/go/ |
| operation.go | 138 func (p Output) Consumers() []Consumer {
147 var consumers []Consumer
148 for _, consumer := range inputs {
149 consumers = append(consumers, Consumer{
150 Index: int(consumer.index),
152 c: consumer.oper,
161 // Consumer identifies a specific input of an operation that consumes the output
163 type Consumer struct {
172 func (p Consumer) c() C.TF_Input {
176 panic("nil-Operation. Consumer objects should only be created by a call to Output.Consumers"
[all...] |
| /external/deqp/framework/delibs/decpp/ |
| deThreadSafeRingBuffer.cpp | 56 class Consumer : public Thread
59 Consumer (ThreadSafeRingBuffer<Message>& buffer, int numProducers)
135 vector<Consumer*> consumers;
141 consumers.push_back(new Consumer(buffer, numProducers));
144 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
160 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
179 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
|
| deBlockBuffer.cpp | 59 class Consumer : public Thread
62 Consumer (MessageBuffer& buffer, int numProducers)
172 vector<Consumer*> consumers;
178 consumers.push_back(new Consumer(buffer, numProducers));
181 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
199 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
218 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
265 class Consumer : public Thread
268 Consumer (BlockBuffer<deUint8>* buffer, deUint32 seed)
314 threads.push_back(new Consumer(&buffer, rnd.getUint32()))
[all...] |
| /external/clang/unittests/Tooling/ |
| ToolingTest.cpp | 31 /// Takes an ast consumer and returns it from CreateASTConsumer. This only
476 TestDiagnosticConsumer Consumer;
477 Tool.setDiagnosticConsumer(&Consumer);
481 EXPECT_EQ(1u, Consumer.NumDiagnosticsSeen);
488 TestDiagnosticConsumer Consumer;
489 Tool.setDiagnosticConsumer(&Consumer);
493 EXPECT_EQ(1u, Consumer.NumDiagnosticsSeen);
|
| /cts/hostsidetests/jvmti/redefining/app/src/android/jvmti/cts/ |
| JvmtiRedefineClassesTest.java | 71 interface Consumer<T> {
75 static class StringCollector implements Consumer<String> {
93 // NB This field has type Landroid/jvmti/cts/JvmtiRedefineClassesTest$Consumer;
94 private Consumer<String> reporter;
96 public Transform(Consumer<String> reporter) {
160 * // NB This field has type Landroid/jvmti/cts/JvmtiRedefineClassesTest$Consumer;
161 * private Consumer<String> reporter;
162 * public Transform(Consumer<String> reporter) {
224 // The consumer that we use to observe the changes to the Transform class.
365 * private Consumer<String> reporter
[all...] |
| /dalvik/dx/src/com/android/dx/cf/direct/ |
| ClassPathOpener.java | 41 private final Consumer consumer; field in class:ClassPathOpener
53 public interface Consumer {
70 * Informs consumer that an exception occurred while processing
78 * Informs consumer that processing of an archive file has begun.
111 * @param consumer {@code non-null;} callback interface
113 public ClassPathOpener(String pathname, boolean sort, Consumer consumer) {
114 this(pathname, sort, acceptAll, consumer);
124 * @param consumer {@code non-null;} callback interfac
[all...] |
| /external/clang/lib/Frontend/ |
| FrontendAction.cpp | 140 std::unique_ptr<ASTConsumer> Consumer = CreateASTConsumer(CI, InFile);
141 if (!Consumer)
144 // If there are no registered plugins we don't need to wrap the consumer
146 return Consumer;
180 // Add to Consumers the main consumer, then all the plugins that go after it
181 Consumers.push_back(std::move(Consumer));
235 // Create the AST consumer.
329 // Create the AST context and consumer unless this is a preprocessor only
336 std::unique_ptr<ASTConsumer> Consumer =
338 if (!Consumer)
[all...] |
| /external/clang/unittests/Lex/ |
| PPCallbacksTest.cpp | 218 ASTConsumer Consumer;
219 Sema S(PP, Context, Consumer);
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| TsiTest.java | 25 import io.grpc.alts.internal.TsiFrameProtector.Consumer;
132 new Consumer<ByteBuf>() {
266 new Consumer<ByteBuf>() {
307 new Consumer<ByteBuf>() {
346 new Consumer<ByteBuf>() {
385 new Consumer<ByteBuf>() {
|
| /external/swiftshader/third_party/llvm-7.0/llvm/lib/Target/Hexagon/MCTargetDesc/ |
| HexagonMCChecker.cpp | 416 auto Consumer = HexagonMCInstrInfo::predicateInfo(MCII, I);
420 auto Producer = registerProducer(Op.getReg(), Consumer);
422 reportError(I.getLoc(), "New value register consumer has no producer");
428 (!Consumer.isPredicated() ||
432 "Register producer is predicated and consumer is unconditional");
438 std::get<2>(Producer).Register != Consumer.Register) {
441 "register as the consumer");
447 if (std::get<2>(Producer).Register == Consumer.Register &&
448 Consumer.PredicatedTrue != std::get<2>(Producer).PredicatedTrue) {
451 "Register producer has the opposite predicate sense as consumer");
[all...] |
| /external/clang/include/clang/Frontend/ |
| CompilerInstance.h | 99 /// The AST consumer.
100 std::unique_ptr<ASTConsumer> Consumer;
102 /// The code completion consumer.
473 bool hasASTConsumer() const { return (bool)Consumer; }
476 assert(Consumer && "Compiler instance has no AST consumer!");
477 return *Consumer;
480 /// takeASTConsumer - Remove the current AST consumer and give ownership to
482 std::unique_ptr<ASTConsumer> takeASTConsumer() { return std::move(Consumer); }
484 /// setASTConsumer - Replace the current AST consumer; the compiler instanc
[all...] |
