- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 241 for Flow (0.02 seconds)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension @Flaky @Tag("Slow") class WebSocketHttpTest { // Flaky https://github.com/square/okhttp/issues/4515 // Flaky https://github.com/square/okhttp/issues/4953 @RegisterExtension var clientTestRule = configureClientTestRule()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 35.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/primitives/DoublesTest.java
} } } } } } } } @AndroidIncompatible // slow @GwtIncompatible // Doubles.tryParse public void testTryParseAllCodePoints() { // Exercise non-ASCII digit test cases and the like. char[] tmp = new char[2];Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 01:43:32 GMT 2026 - 30.9K bytes - Click Count (0) -
guava/src/com/google/common/collect/CompactLinkedHashMap.java
} private static final int ENDPOINT = -2; /** * Contains the link pointers corresponding with the entries, in the range of [0, size()). The * high 32 bits of each long is the "prev" pointer, whereas the low 32 bits is the "succ" pointer * (pointing to the next entry in the linked list). The pointers in [size(), entries.length) are * all "null" (UNSET). *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 10.2K bytes - Click Count (0) -
.teamcity/src/main/kotlin/model/CIBuildModel.kt
val extraParameters: String = "", ) { PER_COMMIT( displayName = "Performance Regression Test", timeout = 420, channel = "commits", ), PER_DAY( displayName = "Slow Performance Regression Test", timeout = 420, channel = "commits", ), PER_WEEK( displayName = "Performance Experiment", timeout = 420, channel = "experiments",Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jan 20 03:53:25 GMT 2026 - 27.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt
import okio.GzipSink import okio.Sink import okio.Source import okio.buffer import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension @Tag("Slow") class InterceptorTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() @StartStop private val server = MockWebServer() private var client = clientTestRule.newClient()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 28.2K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/CompactHashSet.java
/** * Contains the logical entries, in the range of [0, size()). The high bits of each int are the * part of the smeared hash of the element not covered by the hashtable mask, whereas the low bits * are the "next" pointer (pointing to the next entry in the bucket chain), which will always be * less than or equal to the hashtable mask. * * <pre> * hash = aaaaaaaa * mask = 00000fff
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 23.9K bytes - Click Count (0) -
android/guava/src/com/google/common/primitives/ImmutableLongArray.java
* of values that will be added, if that knowledge is readily available. It is better to guess a * value slightly too high than slightly too low. If the value is not exact, the {@link * ImmutableLongArray} that is built will very likely occupy more memory than strictly necessary; * to trim memory usage, build using {@code builder.build().trimmed()}. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 12 14:49:24 GMT 2025 - 22K bytes - Click Count (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
final boolean threadStarted; /** Constructs a new queue. */ public FinalizableReferenceQueue() { // We could start the finalizer lazily, but I'd rather it blow up early. queue = new ReferenceQueue<>(); frqRef = new PhantomReference<>(this, queue); boolean threadStarted = false; try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 19:26:59 GMT 2026 - 15.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableCollection.java
* worse, and possibly better, than creating a mutable collection and copying it. * <li>Implementations generally do not cache hash codes. If your element or key type has a slow * {@code hashCode} implementation, it should cache it itself. * </ul> * * <h4>Example usage</h4> * * {@snippet : * class Foo { * private static final ImmutableSet<String> RESERVED_CODES =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 21.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
import okio.Socket import okio.buffer import okio.inMemorySocketPair import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test @Tag("Slow") class RealWebSocketTest { // NOTE: Fields are named 'client' and 'server' for cognitive simplicity. This differentiation has // zero effect on the behavior of the WebSocket API which is why tests are only written onceCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 18.7K bytes - Click Count (0)