Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 351 - 360 of 494 for Callbacks (0.05 seconds)

  1. src/main/java/org/codelibs/fess/opensearch/log/allcommon/EsAbstractEntity.java

            public RequestOptionCall<DeleteRequestBuilder> deleteOption() {
                return deleteOption;
            }
        }
    
        @FunctionalInterface
        public interface RequestOptionCall<OP> {
            void callback(OP op);
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  3. docs/es/docs/advanced/async-tests.md

    cuando usas [MotorClient de MongoDB](https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop)), recuerda crear instances de objetos que necesiten un loop de eventos solo dentro de funciones async, por ejemplo, en un callback `@app.on_event("startup")`.
    
    ///...
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 4K bytes
    - Click Count (0)
  4. docs/fr/docs/advanced/async-tests.md

    [MotorClient de MongoDB](https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop)), n'oubliez pas d'instancier les objets qui ont besoin d'une boucle d'événements uniquement dans des fonctions async, par exemple dans un callback `@app.on_event("startup")`.
    
    ///...
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 4.3K bytes
    - Click Count (0)
  5. src/main/assemblies/files/service.bat

    	goto foundJVM
    )
    
    rem Check 'server' JRE (JRE installed on Windows Server)
    if exist "%JAVA_HOME%"\bin\server\jvm.dll (
    	set JVM_DLL=\bin\server\jvm.dll
    	goto foundJVM
    )
    
    rem Fallback to 'client' JRE
    if exist "%JAVA_HOME%"\bin\client\jvm.dll (
    	set JVM_DLL=\bin\client\jvm.dll
    	echo Warning: JAVA_HOME points to a JRE and not JDK installation; a client (not a server^) JVM will be used...
    ) else (
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 15 06:32:15 GMT 2023
    - 6K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/smb1/NtlmAuthenticator.java

     */
    
    /**
     * An abstract class for NTLM authentication in SMB1 protocol.
     * Provides a callback mechanism for retrieving user credentials when authentication is required.
     */
    public abstract class NtlmAuthenticator {
    
        /**
         * Default constructor.
         */
        protected NtlmAuthenticator() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        }
    
        assertEquals(1, logHandler.getStoredLogRecords().size());
        assertThat(logHandler.getStoredLogRecords().get(0).getMessage())
            .isEqualTo("Exception while executing callback: MyListener custom-label");
      }
    
      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = newFixedThreadPool(4);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        }
    
        assertEquals(1, logHandler.getStoredLogRecords().size());
        assertThat(logHandler.getStoredLogRecords().get(0).getMessage())
            .isEqualTo("Exception while executing callback: MyListener custom-label");
      }
    
      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = newFixedThreadPool(4);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

          )
    
        client =
          clientTestRule
            .newClientBuilder()
            .eventListenerFactory(clientTestRule.wrap(eventRecorder))
            .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks.
            .dns { dnsResults }
            .fastFallback(true)
            .build()
        url =
          serverIpv4
            .url("/")
            .newBuilder()
            .host("localhost")
            .build()
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  10. tests/transaction_test.go

    	}
    }
    
    func TestDeeplyNestedTransactionWithBlockAndWrappedCallback(t *testing.T) {
    	transaction := func(ctx context.Context, db *gorm.DB, callback func(ctx context.Context, db *gorm.DB) error) error {
    		return db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
    			return callback(ctx, tx)
    		})
    	}
    	var (
    		user  = *GetUser("transaction-nested", Config{})
    		user1 = *GetUser("transaction-nested-1", Config{})
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 13.3K bytes
    - Click Count (0)
Back to Top