- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 542 for __callback (0.15 sec)
-
okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt
package okhttp3.coroutines import kotlin.coroutines.resumeWithException import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.suspendCancellableCoroutine import okhttp3.Call import okhttp3.Callback import okhttp3.Response import okhttp3.internal.closeQuietly import okio.IOException @ExperimentalCoroutinesApi // resume with a resource cleanup. suspend fun Call.executeAsync(): Response =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 1.5K bytes - Viewed (0) -
docs_src/openapi_callbacks/tutorial001.py
* Send a notification back to the API user (the external developer), as a callback. * At this point is that the API will somehow send a POST request to the external API with the notification of the invoice event (e.g. "payment successful"). """ # Send the invoice, collect the money, send the notification (the callback)
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 14 11:59:59 UTC 2022 - 1.3K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsDataService.java
} public List<EsAccessResult> getAccessResultList(final Consumer<SearchRequestBuilder> callback) { final SearchResponse response = getClient().get(c -> { final SearchRequestBuilder builder = c.prepareSearch(index); callback.accept(builder); builder.setFetchSource(new String[] { "parentUrl", "method", "mimeType", "sessionId", "url", "executionTime", "createTime",
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 8.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/initialization/DefaultBuildCancellationToken.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 17 10:39:11 UTC 2019 - 2.4K bytes - Viewed (0) -
pkg/cache/ttlCache_test.go
} type callbackRecorder struct { callbacks int64 } func (c *callbackRecorder) callback(key, value any) { atomic.AddInt64(&c.callbacks, 1) } func TestTTLEvictionCallback(t *testing.T) { c := &callbackRecorder{callbacks: 0} ttl := NewTTLWithCallback(50*time.Millisecond, time.Millisecond, c.callback) testCacheEvicter(ttl) if atomic.LoadInt64(&c.callbacks) != 1 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/AbstractDataStore.java
import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.core.misc.Pair; import org.codelibs.fess.Constants; import org.codelibs.fess.ds.callback.IndexUpdateCallback; import org.codelibs.fess.entity.DataStoreParams; import org.codelibs.fess.es.config.exentity.DataConfig; import org.codelibs.fess.helper.CrawlingInfoHelper; import org.codelibs.fess.helper.SystemHelper;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.3K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
""" |retry | """.trimMargin(), ) assertThat(callbacks).isEmpty() } private fun consumeEvents(source: String) { val callback: ServerSentEventReader.Callback = object : ServerSentEventReader.Callback { override fun onEvent( id: String?, type: String?, data: String, ) { callbacks.add(Event(id, type, data))
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher_test.go
t.Fatalf("callback should not be called") }), true) // Create CRD later saCalls := atomic.NewInt32(0) // When should return false assert.Equal(t, ctl.KnownOrCallback(gvr.ServiceAccount, func(s <-chan struct{}) { assert.Equal(t, s, stop) saCalls.Inc() }), false) clienttest.MakeCRD(t, c, gvr.ServiceAccount) // And call the callback when the CRD is created
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
client.newCall(Request.Builder().url(server.url("/a")).build()).enqueue(callback) callback.await(server.url("/a")).assertBody("abc") client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback) callback.await(server.url("/b")).assertBody("def") client.newCall(Request.Builder().url(server.url("/c")).build()).enqueue(callback) callback.await(server.url("/c")).assertBody("ghi")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/AsynchronousGet.java
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.recipes; import java.io.IOException; import okhttp3.Call; import okhttp3.Callback; import okhttp3.Headers; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; import okhttp3.ResponseBody; public final class AsynchronousGet {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun May 22 01:29:42 UTC 2016 - 1.9K bytes - Viewed (0)