- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 410 for Callbacks (0.06 sec)
-
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) -
guava/src/com/google/common/hash/LittleEndianByteArray.java
* * @author Kevin Damm * @author Kyle Maddison */ final class LittleEndianByteArray { /** * The instance that actually does the work; delegates to VarHandle, Unsafe, or a Java-8 * compatible pure-Java fallback. */ private static final LittleEndianBytes byteArray = makeGetter(); /** * Load 8 bytes into long in a little endian manner, from the substring between position and
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 12 03:49:18 UTC 2025 - 12.3K 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) -
src/test/java/jcifs/smb/Kerb5AuthenticatorTest.java
assertTrue(ex.getMessage().contains("Cannot use netbios/short names")); } @Test @DisplayName("createContext: no Kerberos in initial token and no fallback -> throws") void createContext_noKerberosNoFallback_throws() throws CIFSException { Kerb5Authenticator auth = new Kerb5Authenticator((Subject) null);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
* selected in the static initializer of AbstractFuture. This is convenient and performant but * introduces some testing difficulties. This test exercises the fallback strategies. * * <p>To force selection of our fallback strategies, we load {@link AbstractFuture} (and all of * {@code com.google.common.util.concurrent}) in degenerate class loaders which make certain * platform classes unavailable. Then we construct a test suite so we can run the normal
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 7.3K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java
private final String id; private final ArtifactRepositoryLayout fallback; UnknownRepositoryLayout(String id, ArtifactRepositoryLayout fallback) { this.id = id; this.fallback = fallback; } @Override public String getId() { return id; } @Override
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 31.2K 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)