- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 391 for crossed (0.05 sec)
-
guava-tests/test/com/google/common/collect/GeneralRangeTest.java
assertEquals( GeneralRange.range(ORDERING, 3, CLOSED, 4, OPEN), range.intersect(GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED))); } public void testIntersectOverlappingRange() { GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED); assertEquals( GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED),
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt
override fun close() { closed.set(true) super.close() } }.buffer() } } body.charStream().close() assertThat(closed.get()).isTrue() } @Test fun readerClosedAfterBomClosesUnderlyingSource() { val closed = AtomicBoolean() val body: ResponseBody = object : ResponseBody() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 12.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ContiguousSetTest.java
assertFalse(set.containsAll((Collection<?>) ImmutableSet.of("blah"))); } public void testRange() { assertEquals(Range.closed(1, 3), ContiguousSet.create(Range.closed(1, 3), integers()).range()); assertEquals(Range.closed(1, 3), ContiguousSet.closed(1, 3).range()); assertEquals(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/MultisetNavigationTester.java
testEmptyRangeSubMultiset( sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), OPEN)); testEmptyRangeSubMultiset( sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), CLOSED)); testEmptyRangeSubMultiset( sortedMultiset.subMultiset(b.getElement(), CLOSED, a.getElement(), CLOSED)); testEmptyRangeSubMultiset(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 20:14:36 UTC 2024 - 26K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} else { openClientSockets.add(socket) serveConnection(nextConnectionIndex++, socket, peek) } } } public override fun close() { if (closed) return closed = true if (!started) return // Nothing to shut down. val serverSocket = this.serverSocket ?: return // If this is null, start() must have failed. // Cause acceptConnections() to break out.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 20:36:00 UTC 2025 - 40.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
} @Throws(IOException::class) fun flush() { withLock { if (closed) throw IOException("closed") sink.flush() } } @Throws(IOException::class) fun rstStream( streamId: Int, errorCode: ErrorCode, ) { withLock { if (closed) throw IOException("closed") require(errorCode.httpCode != -1) frameHeader( streamId = streamId,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11K bytes - Viewed (0) -
src/test/java/jcifs/util/SimpleCircuitBreakerTest.java
} @Test @DisplayName("Test initial state is CLOSED") void testInitialState() { assertEquals(SimpleCircuitBreaker.State.CLOSED, circuitBreaker.getState()); assertTrue(circuitBreaker.allowsRequests()); } @Test @DisplayName("Test successful calls in CLOSED state") void testSuccessfulCalls() throws Exception {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
) : ForwardingSink(delegate) { private var completed = false private var bytesReceived = 0L private var closed = false @Throws(IOException::class) override fun write( source: Buffer, byteCount: Long, ) { check(!closed) { "closed" } if (contentLength != -1L && bytesReceived + byteCount > contentLength) { throw ProtocolException(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
server.processNextFrame() // Not closed until close reply is received. assertThat(client.closed).isFalse() server.sink.write("0a00".decodeHex()).emit() // Invalid non-final ping frame. client.processNextFrame() // Detects error, disconnects immediately since close already sent. client.webSocket!!.finishReader() taskFaker.runTasks() assertThat(client.closed).isTrue() client.listener.assertFailure(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/TreeRangeMapTest.java
assertEquals( ImmutableMap.of(Range.closedOpen(5, 7), 1, Range.closed(9, 10), 2), sub.asMapOfRanges()); sub.putCoalescing(Range.closed(7, 9), 2); assertEquals( ImmutableMap.of(Range.closedOpen(5, 7), 1, Range.closed(7, 10), 2), sub.asMapOfRanges()); assertEquals( ImmutableMap.of(Range.open(3, 7), 1, Range.closed(7, 10), 2, Range.closed(12, 16), 3),
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 30K bytes - Viewed (0)