- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 98 for outputId (0.17 sec)
-
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
public void testFutureGetThrowsCancellationIfOutputCancelled() throws Exception { inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); outputFuture.cancel(true); // argument is ignored assertThrows(CancellationException.class, () -> resultFuture.get()); } public void testAsyncToString() throws Exception { inputFuture.set(SLOW_OUTPUT_VALID_INPUT_DATA); assertThat(resultFuture.toString()).contains(outputFuture.toString()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AsyncFunction.java
* @since 11.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface AsyncFunction<I extends @Nullable Object, O extends @Nullable Object> { /** * Returns an output {@code Future} to use in place of the given {@code input}. The output {@code * Future} need not be {@linkplain Future#isDone done}, making {@code AsyncFunction} suitable for * asynchronous derivations. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Sun Jun 20 10:45:35 GMT 2021 - 1.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/HashBiMap.java
// requireNonNull is safe because of the hasNext check. BiEntry<K, V> entry = requireNonNull(next); next = entry.nextInKeyInsertionOrder; toRemove = entry; remaining--; return output(entry); } @Override public void remove() { if (modCount != expectedModCount) { throw new ConcurrentModificationException(); } if (toRemove == null) {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Oct 13 14:11:58 GMT 2023 - 24.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hasher.java
* char} are hashed directly (in that order). The input must not be updated while this method is * in progress. * * <p><b>Warning:</b> This method will produce different output than most other languages do when * running the same hash function on the equivalent input. For cross-language compatibility, use * {@link #putString}, usually with a charset of UTF-8. For other use cases, use {@code
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jun 15 20:59:00 GMT 2022 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Joiner.java
* Multimap} entries in two distinct modes: * * <ul> * <li>To output a separate entry for each key-value pair, pass {@code multimap.entries()} to a * {@code MapJoiner} method that accepts entries as input, and receive output of the form * {@code key1=A&key1=B&key2=C}. * <li>To output a single entry for each key, pass {@code multimap.asMap()} to a {@code
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 18.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AsyncCallable.java
* result. * * @since 20.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface AsyncCallable<V extends @Nullable Object> { /** * Computes a result {@code Future}. The output {@code Future} need not be {@linkplain * Future#isDone done}, making {@code AsyncCallable} suitable for asynchronous derivations. * * <p>Throwing an exception from this method is equivalent to returning a failing {@link
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Dec 14 15:53:12 GMT 2021 - 1.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestCharSink.java
} @Override public boolean wasStreamClosed() { return byteSink.wasStreamClosed(); } @Override public Writer openStream() throws IOException { // using TestByteSink's output stream to get option behavior, so flush to it on every write return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) { @Override public void write(int c) throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Apr 21 02:27:51 GMT 2017 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* primary input succeeds, it is never invoked. If, during the invocation of {@code fallback}, an * exception is thrown, this exception is used as the result of the output {@code Future}. * * <p>Usage example: * * <pre>{@code * // Falling back to a zero counter in case an exception happens when processing the RPC to fetch * // counters.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
return newReentrantLock(lockName, false); } /** * Creates a {@link ReentrantLock} with the given fairness policy. The {@code lockName} is used in * the warning or exception output to help identify the locks involved in the detected deadlock. */ public ReentrantLock newReentrantLock(String lockName, boolean fair) { return policy == Policies.DISABLED ? new ReentrantLock(fair)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 35.9K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilderSpec.java
return builder; } /** * Returns a string that can be used to parse an equivalent {@code CacheBuilderSpec}. The order * and form of this representation is not guaranteed, except that reparsing its output will * produce a {@code CacheBuilderSpec} equal to this instance. */ public String toParsableString() { return specification; } /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Aug 22 14:27:44 GMT 2022 - 18.1K bytes - Viewed (0)