Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 71 for newBuilder (0.28 sec)

  1. okhttp/src/main/kotlin/okhttp3/Response.kt

      @JvmName("-deprecated_body")
      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "body"),
        level = DeprecationLevel.ERROR,
      )
      fun body() = body
    
      fun newBuilder(): Builder = commonNewBuilder()
    
      /** Returns true if this response redirects to another resource. */
      val isRedirect: Boolean = commonIsRedirect
    
      @JvmName("-deprecated_networkResponse")
      @Deprecated(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/DispatcherTest.kt

          .containsExactlyInAnyOrder(a4, a5)
      }
    
      @Test
      fun synchronousCallAccessors() {
        val ready = CountDownLatch(2)
        val waiting = CountDownLatch(1)
        client =
          client.newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                try {
                  ready.countDown()
                  waiting.await()
                } catch (e: InterruptedException) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Fri Apr 05 03:30:42 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

        protected LoadingCache<String, StatsObject> statsCache;
    
        @PostConstruct
        public void init() {
            statsLogger = LogManager.getLogger(loggerName);
            statsCache = CacheBuilder.newBuilder().maximumSize(maxCacheSize).expireAfterWrite(cacheExpireAfterWrite, TimeUnit.MILLISECONDS)
                    .build(new CacheLoader<String, StatsObject>() {
                        @Override
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/CrawlingConfigHelper.java

        @PostConstruct
        public void init() {
            if (logger.isDebugEnabled()) {
                logger.debug("Initialize {}", this.getClass().getSimpleName());
            }
            crawlingConfigCache = CacheBuilder.newBuilder().maximumSize(100).expireAfterWrite(10, TimeUnit.MINUTES).build();
        }
    
        public ConfigType getConfigType(final String configId) {
            if (configId == null || configId.length() < 2) {
                return null;
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 11.7K bytes
    - Viewed (0)
  5. maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/MavenModelMerger.java

            Site src = source.getSite();
            if (src != null) {
                Site tgt = target.getSite();
                if (tgt == null) {
                    tgt = Site.newBuilder(false).build();
                }
                Site.Builder sbuilder = Site.newBuilder(tgt);
                if (sourceDominant || tgt == null || isSiteEmpty(tgt)) {
                    mergeSite(sbuilder, tgt, src, sourceDominant, context);
                }
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

            .validityInterval(1, 2)
            .build()
        var client = buildClient(clientCert, clientIntermediateCa.certificate)
        val listener = RecordingEventListener()
        client =
          client.newBuilder()
            .eventListener(listener)
            .build()
        val socketFactory = buildServerSslSocketFactory()
        server.useHttps(socketFactory)
        server.requireClientAuth()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          return
        }
    
        val webSocketClient =
          client.newBuilder()
            .eventListener(EventListener.NONE)
            .protocols(ONLY_HTTP1)
            .build()
        val request =
          originalRequest.newBuilder()
            .header("Upgrade", "websocket")
            .header("Connection", "Upgrade")
            .header("Sec-WebSocket-Key", key)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

      }
    
      private fun isLoom(): Boolean {
        return getPlatformSystemProperty() == LOOM_PROPERTY
      }
    
      fun newClientBuilder(): OkHttpClient.Builder {
        return newClient().newBuilder()
      }
    
      @Synchronized private fun addEvent(event: String) {
        if (recordEvents) {
          logger?.info(event)
    
          synchronized(clientEventsList) {
            clientEventsList.add(event)
          }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  9. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

          return response
        }
    
        internal fun redactUrl(url: HttpUrl): String {
          if (queryParamsNameToRedact.isEmpty() || url.querySize == 0) {
            return url.toString()
          }
          return url.newBuilder().query(null).apply {
            for (i in 0 until url.querySize) {
              val parameterName = url.queryParameterName(i)
              val newValue = if (parameterName in queryParamsNameToRedact) "██" else url.queryParameterValue(i)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 09:14:38 GMT 2024
    - 11.2K bytes
    - Viewed (1)
  10. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

      }
    
      @Test
      fun configureClientDefault() {
        val request =
          Request.Builder()
            .url(server.url("/"))
            .build()
        val timeoutClient =
          client.newBuilder()
            .callTimeout(Duration.ofMillis(456))
            .build()
        val call = timeoutClient.newCall(request)
        assertThat(call.timeout().timeoutNanos())
          .isEqualTo(TimeUnit.MILLISECONDS.toNanos(456))
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
Back to top