Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newConnections (0.04 sec)

  1. android/guava/src/com/google/common/graph/StandardMutableNetwork.java

       *
       * @throws IllegalStateException if {@code node} is already present
       */
      @CanIgnoreReturnValue
      private NetworkConnections<N, E> addNodeInternal(N node) {
        NetworkConnections<N, E> connections = newConnections();
        checkState(nodeConnections.put(node, connections) == null);
        return connections;
      }
    
      @Override
      @CanIgnoreReturnValue
      public boolean addEdge(N nodeU, N nodeV, E edge) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        assertThat(c1.socket().isClosed).isFalse()
      }
    
      @Test fun cleanupPrioritizesEarliestEviction() {
        val pool = factory.newConnectionPool()
        val c1 = factory.newConnection(pool, routeA1, 75L)
        val c2 = factory.newConnection(pool, routeB1, 50L)
    
        // Running at time 75, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(75L)).isEqualTo(75L)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt

      inner class FakePlan(
        val id: Int,
      ) : RoutePlanner.Plan {
        var planningThrowable: Throwable? = null
        var canceled = false
        var connectState = ConnectState.READY
        val connection =
          factory.newConnection(
            pool = pool,
            route = factory.newRoute(address),
            idleAtNanos = defaultConnectionIdleAtNanos,
          )
        var retry: FakePlan? = null
        var retryTaken = false
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

      var hostnameVerifier: HostnameVerifier? = HttpsURLConnection.getDefaultHostnameVerifier()
      var uriHost: String = "example.com"
      var uriPort: Int = 1
    
      fun newConnection(
        pool: RealConnectionPool,
        route: Route,
        idleAtNanos: Long = Long.MAX_VALUE,
        taskRunner: TaskRunner = this.taskRunner,
      ): RealConnection {
        val result =
          RealConnection.newTestConnection(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

              localCertificates = listOf(),
            )
    
          return mapOf(
            Boolean::class.java to false,
            Call::class.java to FailingCall(),
            Connection::class.java to factory.newConnection(pool, route),
            Dispatcher::class.java to Dispatcher(),
            Handshake::class.java to handshake,
            HttpUrl::class.java to url,
            IOException::class.java to IOException("boom"),
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.5K bytes
    - Viewed (0)
Back to top