| /external/jimfs/jimfs/src/main/java/com/google/common/jimfs/ |
| D | FileSystemState.java | 40 private final Runnable onClose; field in FileSystemState
47 FileSystemState(Runnable onClose) { in FileSystemState() argument
48 this.onClose = checkNotNull(onClose); in FileSystemState()
99 onClose.run(); in close()
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | FileSystemStateTest.java | 42 private final TestRunnable onClose = new TestRunnable(); field in FileSystemStateTest
43 private final FileSystemState state = new FileSystemState(onClose);
65 assertEquals(0, onClose.runCount); in testClose_callsOnCloseRunnable()
67 assertEquals(1, onClose.runCount); in testClose_callsOnCloseRunnable()
73 assertEquals(1, onClose.runCount); in testClose_multipleTimesDoNothing()
76 assertEquals(1, onClose.runCount); in testClose_multipleTimesDoNothing()
|
| /external/oboe/apps/OboeTester/app/src/main/java/com/mobileer/miditools/ |
| D | MidiOutputPortConnectionSelector.java | 58 onClose(); in onPortSelected()
72 public void onClose() { in onClose() method in MidiOutputPortConnectionSelector
81 super.onClose(); in onClose()
|
| D | MidiOutputPortSelector.java | 77 public void onClose() { in onClose() method in MidiOutputPortSelector
90 super.onClose(); in onClose()
|
| D | MidiInputPortSelector.java | 76 public void onClose() { in onClose() method in MidiInputPortSelector
90 super.onClose(); in onClose()
|
| D | MidiPortSelector.java | 175 public void onClose() { in onClose() method in MidiPortSelector
189 onClose(); in close()
|
| /external/guava/guava/src/com/google/common/collect/ |
| D | Streams.java | 178 .onClose(() -> closeAll(streams)); in concat()
210 .onClose(() -> closeAll(streams)); in concat()
242 .onClose(() -> closeAll(streams)); in concat()
274 .onClose(() -> closeAll(streams)); in concat()
330 .onClose(streamA::close) in zip()
331 .onClose(streamB::close); in zip()
439 .onClose(stream::close);
471 return StreamSupport.stream(new Splitr(fromSpliterator, 0), isParallel).onClose(stream::close);
521 .onClose(stream::close);
550 return StreamSupport.stream(new Splitr(fromSpliterator, 0), isParallel).onClose(stream::close);
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingClientCallListener.java | 38 public void onClose(Status status, Metadata trailers) { in onClose() method in PartialForwardingClientCallListener
39 delegate().onClose(status, trailers); in onClose()
|
| D | ClientCall.java | 144 public void onClose(Status status, Metadata trailers) {} in onClose() method in ClientCall.Listener
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | StreamsTest.java | 91 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated()
102 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated_Stream_concat()
114 Stream<String> streamB = Stream.of("b").onClose(closeCountB::incrementAndGet); in testConcat_refStream_closeIsPropagated_Stream_flatMap()
239 Stream<String> strings = source.onClose(stringsCloseCount::incrementAndGet); in testMapWithIndex_closeIsPropagated()
264 IntStream intStream = source.onClose(intStreamCloseCount::incrementAndGet); in testMapWithIndex_intStream_closeIsPropagated()
289 LongStream longStream = source.onClose(longStreamCloseCount::incrementAndGet); in testMapWithIndex_longStream_closeIsPropagated()
316 DoubleStream doubleStream = source.onClose(doubleStreamCloseCount::incrementAndGet); in testMapWithIndex_doubleStream_closeIsPropagated()
332 Stream<String> letters = Stream.of("a", "b", "c").onClose(lettersCloseCount::incrementAndGet); in testZip_closeIsPropagated()
334 Stream<Integer> numbers = Stream.of(1, 2, 3).onClose(numbersCloseCount::incrementAndGet); in testZip_closeIsPropagated()
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/stream/ |
| D | ConsumeAsFlowTest.kt | 25 assertEquals(list, list.stream().onClose { expect(2) }.consumeAsFlow().toList()) in <lambda>()
32 val flow = list.stream().onClose { expect(2) } .consumeAsFlow() in <lambda>()
|
| /external/perfetto/ui/src/controller/ |
| D | adb_interfaces.ts | 34 onClose: VoidCallback; property
69 onClose = () => {}; property in MockAdbStream
|
| D | adb_shell_controller.ts | 89 this.recordShell.onClose = () => {
115 readTraceShell.onClose = () => {
|
| D | adb.ts | 295 stream.onClose = () => {};
298 stream.onClose = () => reject();
308 shell.onClose = () => resolve(output.join());
411 onClose = () => {}; property in AdbStreamImpl
445 this.onClose();
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptor.java | 237 public void onClose(Status status, Metadata trailers) {
241 super.onClose(
244 super.onClose(status, trailers);
277 interceptedListener.onClose(Status.OK, metadata);
|
| /external/skqp/src/xps/ |
| D | SkXPSDocument.cpp | 32 void onClose(SkWStream*) override;
70 void SkXPSDocument::onClose(SkWStream*) { in onClose() function in SkXPSDocument
|
| /external/skia/src/xps/ |
| D | SkXPSDocument.cpp | 32 void onClose(SkWStream*) override;
69 void SkXPSDocument::onClose(SkWStream*) { in onClose() function in SkXPSDocument
|
| /external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 108 @Override public void onClose(int code, String reason) { in runTest()
147 @Override public void onClose(int code, String reason) { in getTestCount()
182 @Override public void onClose(int code, String reason) { in updateReports()
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | WebSocketCallTest.java | 230 @Override public void onClose(int code, String reason) { in awaitWebSocket()
231 listener.onClose(code, reason); in awaitWebSocket()
262 @Override public void onClose(int code, String reason) { in onClose() method in WebSocketCallTest.EmptyWebSocketListener
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 103 listener.onClose(status, trailers); in unaryBlockingCallSuccess()
120 listener.onClose(status, trailers); in unaryBlockingCallFailed()
161 listener.get().onClose(Status.OK, new Metadata()); in unaryFutureCallSuccess()
178 listener.get().onClose(Status.INTERNAL, trailers); in unaryFutureCallFailed()
214 listener.get().onClose(Status.OK, new Metadata()); in unaryFutureCallCancelled()
556 listener.get().onClose(Status.INTERNAL, trailers); in blockingResponseStreamFailed()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | MetadataUtils.java | 170 public void onClose(Status status, Metadata trailers) { in onClose() method in MetadataUtils.MetadataCapturingClientInterceptor.MetadataCapturingClientCall.MetadataCapturingClientCallListener
172 super.onClose(status, trailers); in onClose()
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketListener.java | 72 void onClose(int code, String reason); in onClose() method
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocket.java | 80 @Override public void onClose(final int code, final String reason) { in RealWebSocket()
197 listener.onClose(code, reason); in peerClose()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
| D | FailingClientCall.java | 34 listener.onClose(error, new Metadata()); in start()
|
| /external/skqp/include/core/ |
| D | SkDocument.h | 71 virtual void onClose(SkWStream*) = 0;
|