- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 96 for Finish (6.42 sec)
-
misc/go_android_exec/exitcode_test.go
} // The "pre" output should all have been flushed already. if want, got := pre, out.String(); want != got { t.Errorf("filter should have already flushed %q, but flushed %q", want, got) } code, err := f.Finish() if err != nil { t.Fatal(err) } // Nothing more should have been written to out. if want, got := pre, out.String(); want != got { t.Errorf("want output %q, got %q", want, got) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed May 03 14:54:58 GMT 2023 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineBuffer.java
* or carriage return followed immediately by a linefeed. * * <p>Subclasses must implement {@link #handleLine}, call {@link #add} to pass character data, and * call {@link #finish} at the end of stream. * * @author Chris Nokleberg * @since 1.0 */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault abstract class LineBuffer { /** Holds partial line contents. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 3.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown(); assertEquals(25, task.get().intValue());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/math/LinearTransformation.java
* finite. Call either {@link LinearTransformationBuilder#and} or {@link * LinearTransformationBuilder#withSlope} on the returned object to finish building the instance. */ public static LinearTransformationBuilder mapping(double x1, double y1) { checkArgument(isFinite(x1) && isFinite(y1)); return new LinearTransformationBuilder(x1, y1); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 17:02:53 GMT 2023 - 9.6K bytes - Viewed (0) -
docs/en/docs/async.md
So you wait for your crush to finish the story (finish the current work ⏯ / task being processed 🤓), smile gently and say that you are going for the burgers ⏸.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
} return new ListenableFutureAdapter<>(future, executor); } /** * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the * future to finish, and when it completes, run the listeners. This implementation will wait on * the source future indefinitely, so if the source future never completes, the adapter will never * complete either. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 7.5K bytes - Viewed (0) -
internal/s3select/message.go
writer.payloadBufferIndex = 0 } return result } // Finish is the last call to the message writer - it sends any // remaining record payload, then sends statistics and finally the end // message. func (writer *messageWriter) Finish(bytesScanned, bytesProcessed int64) error { select { case <-writer.doneCh: return fmt.Errorf("messageWriter is done") default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/CollectorTester.java
A finalAccum = scheme.result(collector, inputs); if (collector.characteristics().contains(Collector.Characteristics.IDENTITY_FINISH)) { @SuppressWarnings("unchecked") // `R` and `A` match for an `IDENTITY_FINISH` R result = (R) finalAccum; assertEquivalent(expectedResult, result); } assertEquivalent(expectedResult, collector.finisher().apply(finalAccum));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 6.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/LoadingCache.java
* * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. * * <p>Caches loaded by a {@link CacheLoader} will call {@link CacheLoader#load} to load new values
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sat Aug 06 17:12:03 GMT 2022 - 8.3K bytes - Viewed (0)