- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 402 for callBack (0.04 sec)
-
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractBehavior.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jun 21 04:02:44 UTC 2025 - 26.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
import java.net.Socket import java.net.SocketException import java.util.concurrent.CompletableFuture import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import okhttp3.Call import okhttp3.Callback import okhttp3.DelegatingServerSocketFactory import okhttp3.DelegatingSocketFactory import okhttp3.OkHttpClient import okhttp3.OkHttpClientTestRule import okhttp3.Request import okhttp3.RequestBody
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* case of an error. * * @param event the callback to execute on {@link #dispatch} */ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /** * Enqueues an event to be run on currently known listeners, with a label. * * @param event the callback to execute on {@link #dispatch}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt
class WebSocketRecorder( private val name: String, ) : WebSocketListener() { private val events = LinkedBlockingQueue<Any>() private var delegate: WebSocketListener? = null /** Sets a delegate for handling the next callback to this listener. Cleared after invoked. */ fun setNextEventDelegate(delegate: WebSocketListener?) { this.delegate = delegate } override fun onOpen( webSocket: WebSocket, response: Response,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.8K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
import android.net.http.DnsOptions import android.net.http.HttpEngine import android.net.http.HttpException import android.net.http.QuicOptions import android.net.http.UrlRequest import android.net.http.UrlRequest.Callback import android.net.http.UrlRequest.REQUEST_PRIORITY_MEDIUM import android.net.http.UrlResponseInfo import androidx.test.ext.junit.runners.AndroidJUnit4 import androidx.test.filters.SdkSuppress
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/AbstractConfigHelperTest.java
@Override public int load() { loadCallCount.incrementAndGet(); return loadCallback.call(); } public void setLoadCallback(LoadCallback callback) { this.loadCallback = callback; } public int getLoadCallCount() { return loadCallCount.get(); } } @FunctionalInterface interface LoadCallback {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 00:03:47 UTC 2025 - 4.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
import okio.Timeout open class FailingCall : Call { override fun request(): Request = error("unexpected") override fun execute(): Response = error("unexpected") override fun enqueue(responseCallback: Callback): Unit = error("unexpected") override fun cancel(): Unit = error("unexpected") override fun isExecuted(): Boolean = error("unexpected") override fun isCanceled(): Boolean = error("unexpected")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 1.1K bytes - Viewed (0) -
schema/callbacks_test.go
return nil } func TestCallback(t *testing.T) { user, err := schema.Parse(&UserWithCallback{}, &sync.Map{}, schema.NamingStrategy{}) if err != nil { t.Fatalf("failed to parse user with callback, got error %v", err) } for _, str := range []string{"BeforeSave", "AfterCreate"} { if !reflect.Indirect(reflect.ValueOf(user)).FieldByName(str).Interface().(bool) { t.Errorf("%v should be true", str) } }
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Thu Jan 06 07:02:53 UTC 2022 - 939 bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractConditionAggregation.java
/** * @param op The option of condition to be set up. (NotNull) */ void callback(OP op); } @FunctionalInterface public interface OperatorCall<CA extends EsAbstractConditionAggregation> { void callback(CA query); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 12.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
} response.request } val blockingAuthClient = client .newBuilder() .authenticator(authenticator) .build() val callback: Callback = object : Callback { override fun onFailure( call: Call, e: IOException, ) { fail("") } override fun onResponse(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0)