Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 798 for Caller (0.06 sec)

  1. guava/src/com/google/common/util/concurrent/Service.java

       */
      abstract class Listener {
        /**
         * Called when the service transitions from {@linkplain State#NEW NEW} to {@linkplain
         * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first
         * time.
         */
        public void starting() {}
    
        /**
         * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/query/QueryProcessorTest.java

                    calledFirst.set(true);
                    assertFalse(called.get());
                    QueryBuilder builder = chain.execute(context, query, boost);
                    assertTrue(called.get());
                    return builder;
                }
            });
            queryBuilder = queryProcessor.execute(context, query, 1.0f);
            assertTrue(called.get());
            assertTrue(calledFirst.get());
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. callbacks/callmethod.go

    package callbacks
    
    import (
    	"reflect"
    
    	"gorm.io/gorm"
    )
    
    func callMethod(db *gorm.DB, fc func(value interface{}, tx *gorm.DB) bool) {
    	tx := db.Session(&gorm.Session{NewDB: true})
    	if called := fc(db.Statement.ReflectValue.Interface(), tx); !called {
    		switch db.Statement.ReflectValue.Kind() {
    		case reflect.Slice, reflect.Array:
    			db.Statement.CurDestIndex = 0
    			for i := 0; i < db.Statement.ReflectValue.Len(); i++ {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Feb 18 01:20:29 UTC 2023
    - 846 bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/ImmutableList.java

             * requireNonNull is safe because the callers promise to put non-null objects in the first
             * `length` array elements.
             */
            @SuppressWarnings("unchecked") // our callers put only E instances into the array
            E onlyElement = (E) requireNonNull(elements[0]);
            return of(onlyElement);
          default:
            /*
             * The suppression is safe because the callers promise to put non-null objects in the first
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 16 19:14:45 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  5. cni/pkg/ipset/nldeps_mock.go

    func (m *MockedIpsetDeps) ipsetIPHashCreate(name string, v6 bool) error {
    	args := m.Called(name, v6)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) destroySet(name string) error {
    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	args := m.Called(name, ip, ipProto, comment, replace)
    	return args.Error(0)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Service.java

       */
      abstract class Listener {
        /**
         * Called when the service transitions from {@linkplain State#NEW NEW} to {@linkplain
         * State#STARTING STARTING}. This occurs when {@link Service#startAsync} is called the first
         * time.
         */
        public void starting() {}
    
        /**
         * Called when the service transitions from {@linkplain State#STARTING STARTING} to {@linkplain
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  7. cni/pkg/plugin/plugin_test.go

    	ns.ObjectMeta.Labels = map[string]string{label.IoIstioDataplaneMode.Name: constants.DataplaneModeAmbient}
    
    	testCmdAddExpectFail(t, cniConf, pod, ns)
    
    	wasCalled := serverClose()
    	// server called, but errored
    	assert.Equal(t, wasCalled, true)
    }
    
    func TestCmdAddPodWithProxySidecarAmbientEnabledNS(t *testing.T) {
    	serverClose := setupCNIEventClientWithMockServer(false)
    
    	cniConf := buildMockConf(true)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/AbstractCache.java

        /**
         * Records cache hits. This should be called when a cache request returns a cached value.
         *
         * @param count the number of hits to record
         * @since 11.0
         */
        void recordHits(int count);
    
        /**
         * Records cache misses. This should be called when a cache request returns a value that was not
         * found in the cache. This method should be called by the loading thread, as well as by threads
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 9.1K bytes
    - Viewed (0)
  9. fastapi/background.py

    from typing_extensions import Annotated, Doc, ParamSpec
    
    P = ParamSpec("P")
    
    
    class BackgroundTasks(StarletteBackgroundTasks):
        """
        A collection of background tasks that will be called after a response has been
        sent to the client.
    
        Read more about it in the
        [FastAPI docs for Background Tasks](https://fastapi.tiangolo.com/tutorial/background-tasks/).
    
        ## Example
    
        ```python
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Apr 02 02:48:51 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  10. mockwebserver-junit4/src/test/java/mockwebserver3/junit4/MockWebServerRuleTest.kt

        val rule = MockWebServerRule()
        val called = AtomicBoolean()
        val statement: Statement =
          rule.apply(
            object : Statement() {
              override fun evaluate() {
                called.set(true)
                rule.server.url("/").toUrl().openConnection().connect()
              }
            },
            Description.EMPTY,
          )
        statement.evaluate()
        assertThat(called.get()).isTrue()
        try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
Back to top