- Sort Score
- Result 10 results
- Languages All
Results 641 - 650 of 681 for delete (0.04 sec)
-
RealConnectionPool.kt
must only be L455: * accessed by the connection closer task. L456: */ L457: var concurrentCallCapacity: Int = 0 L458: } L459: L460: companion object { L461: fun get(connectionPool: ConnectionPool): RealConnectionPool = connectionPool.delegate L462: L463: private var addressStatesUpdater = L464: AtomicReferenceFieldUpdater.newUpdater( L465: RealConnectionPool::class.java, L466: Map::class.java, L467: "addressStates", L468: ) L469: } L470:}...github.com/square/okhttp/okhttp/src/main/kotlin...Sat Apr 20 17:03:43 UTC 2024 16.2K bytes -
MockWebServer.kt
disconnectHalfway: Boolean, L878: expectedByteCount: Long, L879: socket: Socket, L880: ): Sink { L881: var result: Sink = this L882: L883: if (policy.throttlePeriodNanos > 0L) { L884: result = L885: ThrottledSink( L886: delegate = result, L887: bytesPerPeriod = policy.throttleBytesPerPeriod, L888: periodDelayNanos = policy.throttlePeriodNanos, L889: ) L890: } L891: L892: if (disconnectHalfway) { L893: val halfwayByteCount = L894: ...github.com/square/okhttp/mockwebserver/src/main...Sun Mar 31 17:16:15 UTC 2024 37.4K bytes -
SetsTest.java
ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(serializedForm)); L409: L410: ImmutableSet<?> deserialized = (ImmutableSet<?>) in.readObject(); L411: EnumSet<?> delegate = (EnumSet<?>) in.readObject(); L412: L413: assertEquals(original, deserialized); L414: assertTrue(delegate.remove(SomeEnum.A)); L415: assertTrue(deserialized.contains(SomeEnum.A)); L416: } L417: L418: @J2ktIncompatible L419: @GwtIncompatible // java serialization not supported in GWT. L420:...github.com/google/guava/guava-tests/test/com/go...Wed Oct 30 16:15:19 UTC 2024 48.6K bytes -
RealCall.kt
headers. */ L63: val originalRequest: Request, L64: val forWebSocket: Boolean, L65:) : Call, Cloneable { L66: internal val lock: ReentrantLock = ReentrantLock() L67: L68: private val connectionPool: RealConnectionPool = client.connectionPool.delegate L69: L70: internal val eventListener: EventListener = client.eventListenerFactory.create(this) L71: L72: private val timeout = L73: object : AsyncTimeout() { L74: override fun timedOut() { L75: this@RealCall.cancel() L76: }...github.com/square/okhttp/okhttp/src/main/kotlin...Sat Apr 20 17:03:43 UTC 2024 17.9K bytes -
QueuesTest.java
L44:import org.checkerframework.checker.nullness.qual.Nullable; L45: L46:/** L47: * Tests for {@link Queues}. L48: * L49: * @author Dimitris Andreou L50: */ L51:public class QueuesTest extends TestCase { L52: /* L53: * All the following tests relate to BlockingQueue methods in Queues. L54: */ L55: L56: public static List<BlockingQueue<Object>> blockingQueues() { L57: return ImmutableList.<BlockingQueue<Object>>of( L58: new LinkedBlockingQueue<Object>(), L59: new LinkedBlo...github.com/google/guava/guava-tests/test/com/go...Thu Oct 17 02:42:09 UTC 2024 12.1K bytes -
Http2ConnectionTest.kt
L1471: val startNanos = System.nanoTime() L1472: assertFailsWith<InterruptedIOException> { L1473: stream.takeHeaders() L1474: } L1475: val elapsedNanos = System.nanoTime() - startNanos L1476: awaitWatchdogIdle() L1477: // 200ms delta L1478: assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedNanos).toDouble()) L1479: .isCloseTo(500.0, 200.0) L1480: assertThat(connection.openStreamCount()).isEqualTo(0) L1481: L1482: // Verify the peer received what was expected. L1483:...github.com/square/okhttp/okhttp/src/test/java/o...Sat Apr 20 17:03:43 UTC 2024 75.4K bytes -
fess_message_fr.properties
five framework-embedded messages (don't change key names) L63:# - - - - - - - - - -/ L64:errors.login.failure=La connexion a échoué. L65:errors.app.illegal.transition=Veuillez réessayer en raison d'une transition illégale. L66:errors.app.db.already.deleted=d'autres peuvent être mis à jour, alors réessayez. L67:errors.app.db.already.updated=d'autres peuvent être mis à jour, alors réessayez. L68:errors.app.db.already.exists=données déjà existantes, alors réessayez. L69:errors.app.double.submit.request=Votre...github.com/codelibs/fess/src/main/resources/fes...Mon Feb 06 22:59:17 UTC 2023 14.2K bytes -
IteratorsTest.java
@Override L1442: public List<String> create(final String[] elements) { L1443: final List<String> delegate = newArrayList(elements); L1444: return new ForwardingList<String>() { L1445: @Override L1446: protected List<String> delegate() { L1447: return delegate; L1448: } L1449: L1450: @Override L1451: public boolean removeAll(Collection<?> c) {...github.com/google/guava/guava-tests/test/com/go...Wed Oct 30 16:15:19 UTC 2024 54.1K bytes -
IdnaMappingTable.txt
valid ; ; NV8 # 10.0 OBSERVER EYE SYMBOL L2588:2400..2424 ; valid ; ; NV8 # 1.1 SYMBOL FOR NULL..SYMBOL FOR NEWLINE L2589:2425..2426 ; valid ; ; NV8 # 3.0 SYMBOL FOR DELETE FORM TWO..SYMBOL FOR SUBSTITUTE FORM TWO L2590:2427..243F ; disallowed # NA <reserved-2427>..<reserved-243F> L2591:2440..244A ; valid ; ; NV8 # 1.1 OCR HOOK..OCR DOUBLE BACKSLASH L2592:244B..245F...github.com/square/okhttp/okhttp-idna-mapping-ta...Sat Feb 10 11:25:47 UTC 2024 854.1K bytes -
IteratorsTest.java
@Override L1442: public List<String> create(final String[] elements) { L1443: final List<String> delegate = newArrayList(elements); L1444: return new ForwardingList<String>() { L1445: @Override L1446: protected List<String> delegate() { L1447: return delegate; L1448: } L1449: L1450: @Override L1451: public boolean removeAll(Collection<?> c) {...github.com/google/guava/android/guava-tests/tes...Wed Oct 30 16:15:19 UTC 2024 54.1K bytes