- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for processResponse (0.23 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
*/ package okhttp3.sse.internal import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.OkHttpClientTestRule import okhttp3.Request import okhttp3.sse.EventSources.processResponse import okhttp3.testing.PlatformRule import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic fun processResponse( response: Response, listener: EventSourceListener, ) { val eventSource = RealEventSource(response.request, listener) eventSource.processResponse(response) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:18:15 UTC 2024 - 1.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt
callFactory.newCall(request).apply { enqueue(this@RealEventSource) } } override fun onResponse( call: Call, response: Response, ) { processResponse(response) } fun processResponse(response: Response) { response.use { if (!response.isSuccessful) { listener.onFailure(this, null, response) return } val body = response.body
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/software/resources-http/src/main/java/org/gradle/internal/resource/transport/http/HttpClientHelper.java
return processResponse(performRawHead(source, revalidate)); } HttpClientResponse performRawGet(String source, boolean revalidate) { return performRequest(new HttpGet(source), revalidate); } @Nonnull public HttpClientResponse performGet(String source, boolean revalidate) { return processResponse(performRawGet(source, revalidate)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 13K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Fri Mar 22 07:09:21 UTC 2024 - 9.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
processResponse(urlQueue, responseData); return false; } } finally { if (responseData != null) { CloseableUtil.closeQuietly(responseData); } } } return true; }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 15.5K bytes - Viewed (0) -
okhttp-sse/api/okhttp-sse.api
public static final fun createFactory (Lokhttp3/Call$Factory;)Lokhttp3/sse/EventSource$Factory; public static final synthetic fun createFactory (Lokhttp3/OkHttpClient;)Lokhttp3/sse/EventSource$Factory; public static final fun processResponse (Lokhttp3/Response;Lokhttp3/sse/EventSourceListener;)V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Dec 17 14:39:59 UTC 2023 - 1.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
} } return urlSet; } @Override protected void processResponse(final UrlQueue<?> urlQueue, final ResponseData responseData) { super.processResponse(urlQueue, responseData); final FessConfig fessConfig = ComponentUtil.getFessConfig();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java
}); final OptionalEntity<SearchResponse> searchResponseOpt = sendRequest(query, params, userBean); return processResponse(searchResponseOpt); } protected SearchResult processResponse(final OptionalEntity<SearchResponse> searchResponseOpt) { final FessConfig fessConfig = ComponentUtil.getFessConfig();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/saml/SamlAuthenticator.java
session.removeAttribute(SAML_STATE); try { final Auth auth = new Auth(getSettings(), request, response); auth.processResponse(); if (!auth.isAuthenticated()) { if (logger.isDebugEnabled()) { logger.debug("Authentication is failed.");
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.2K bytes - Viewed (0)