Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 410 for Callbacks (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top