- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Rollback (4 sec)
-
guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
@CheckForNull @LazyInit Class<X> exceptionType; @CheckForNull @LazyInit F fallback; AbstractCatchingFuture( ListenableFuture<? extends V> inputFuture, Class<X> exceptionType, F fallback) { this.inputFuture = checkNotNull(inputFuture); this.exceptionType = checkNotNull(exceptionType); this.fallback = checkNotNull(fallback); } @Override public final void run() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/TearDownStackTest.java
boolean ran = false; @Nullable Callback callback = null; public SimpleTearDown() {} public SimpleTearDown(Callback callback) { this.callback = callback; } @Override public void tearDown() throws Exception { if (callback != null) { callback.run(); } ran = true; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 17 15:19:38 UTC 2023 - 4.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
// we called sizeIfKnown and when we started reading the file (or I guess if // maxCharsPerByte is wrong) // Fallback to an incremental approach StringBuilder builder = new StringBuilder(bufIndex + 32); builder.append(buffer, 0, bufIndex); buffer = null; // release for gc
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 10 19:45:10 UTC 2022 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
* and performant but introduces some testing difficulties. This test exercises the two fallback * strategies. * * <ul> * <li>SafeAtomicHelper: uses Atomic FieldsUpdaters to implement synchronization * <li>SynchronizedHelper: uses {@code synchronized} blocks for synchronization * </ul> * * To force selection of our fallback strategies we load {@link AggregateFutureState} (and all of
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 10 19:45:10 UTC 2022 - 5.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Resources.java
} /** * Streams lines from a URL, stopping when our callback returns false, or we have read all of the * lines. * * @param url the URL to read from * @param charset the charset used to decode the input stream; see {@link Charsets} for helpful * predefined constants * @param callback the LineProcessor to use to handle the lines * @return the output of processing the lines
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 7.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractChainedListenableFutureTest.java
listener = new MockFutureListener(resultFuture); } public void testFutureGetBeforeCallback() throws Exception { // Verify that get throws a timeout exception before the callback is called. assertThrows(TimeoutException.class, () -> resultFuture.get(1L, TimeUnit.MILLISECONDS)); } public void testFutureGetThrowsWrappedException() throws Exception { inputFuture.setException(EXCEPTION);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LittleEndianByteArray.java
* * @author Kevin Damm * @author Kyle Maddison */ @ElementTypesAreNonnullByDefault final class LittleEndianByteArray { /** The instance that actually does the work; delegates to Unsafe or a pure-Java fallback. */ private static final LittleEndianBytes byteArray; /** * Load 8 bytes into long in a little endian manner, from the substring between position and
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 9.7K bytes - Viewed (0) -
guava/src/com/google/common/io/LineProcessor.java
import com.google.common.annotations.J2ktIncompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.io.IOException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A callback to be used with the streaming {@code readLines} methods. * * <p>{@link #processLine} will be called for each line that is read, and should return {@code * false} when you want to stop processing. * * @author Miles Barr
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 1.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteProcessor.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.DoNotMock; import java.io.IOException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A callback interface to process bytes from a stream. * * <p>{@link #processBytes} will be called for each chunk of data that is read, and should return * {@code false} when you want to stop processing. * * @author Chris Nokleberg
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 2K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteProcessor.java
import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.DoNotMock; import java.io.IOException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A callback interface to process bytes from a stream. * * <p>{@link #processBytes} will be called for each chunk of data that is read, and should return * {@code false} when you want to stop processing. * * @author Chris Nokleberg
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 2K bytes - Viewed (0)