Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 696 for called (0.08 sec)

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

         *     State#TERMINATED TERMINATED}.
         */
        public void terminated(State from) {}
    
        /**
         * Called when the service transitions to the {@linkplain State#FAILED FAILED} state. The
         * {@linkplain State#FAILED FAILED} state is a terminal state in the transition diagram.
         * Therefore, if this method is called, no other methods will be called on the {@link Listener}.
    Registered: 2024-11-01 12:43
    - Last Modified: 2023-04-04 09:45
    - 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: 2024-10-31 13:40
    - Last Modified: 2024-02-22 01:37
    - 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: 2024-11-03 09:35
    - Last Modified: 2023-02-18 01:20
    - 846 bytes
    - Viewed (0)
  4. 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: 2024-11-06 22:53
    - Last Modified: 2024-04-30 22:24
    - 1.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

         *     State#TERMINATED TERMINATED}.
         */
        public void terminated(State from) {}
    
        /**
         * Called when the service transitions to the {@linkplain State#FAILED FAILED} state. The
         * {@linkplain State#FAILED FAILED} state is a terminal state in the transition diagram.
         * Therefore, if this method is called, no other methods will be called on the {@link Listener}.
    Registered: 2024-11-01 12:43
    - Last Modified: 2023-04-04 09:45
    - 10.7K bytes
    - Viewed (0)
  6. cni/pkg/plugin/plugin_test.go

    		t.Fatal("Didnt Expect nsenterFunc to be called because this pod does not contain a sidecar")
    	}
    }
    
    func TestCmdAddExcludePod(t *testing.T) {
    	pod, ns := buildFakePodAndNSForClient()
    
    	mockIntercept := testDoAddRun(t, buildMockConf(true), "testExcludeNS", pod, ns)
    	if len(mockIntercept.lastRedirect) != 0 {
    		t.Fatal("failed to exclude pod")
    	}
    }
    
    Registered: 2024-11-06 22:53
    - Last Modified: 2024-10-09 16:05
    - 17.3K bytes
    - Viewed (0)
  7. fastapi/background.py

                Doc(
                    """
                    The function to call after the response is sent.
    
                    It can be a regular `def` function or an `async def` function.
                    """
                ),
            ],
            *args: P.args,
            **kwargs: P.kwargs,
        ) -> None:
            """
            Add a function to be called in the background after the response is sent.
    
            Read more about it in the
    Registered: 2024-11-03 07:19
    - Last Modified: 2024-04-02 02:48
    - 1.7K bytes
    - Viewed (0)
  8. 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: 2024-11-01 11:42
    - Last Modified: 2024-01-08 01:13
    - 1.5K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Callback.kt

    import okio.IOException
    
    interface Callback {
      /**
       * Called when the request could not be executed due to cancellation, a connectivity problem or
       * timeout. Because networks can fail during an exchange, it is possible that the remote server
       * accepted the request before the failure.
       */
      fun onFailure(
        call: Call,
        e: IOException,
      )
    
      /**
    Registered: 2024-11-01 11:42
    - Last Modified: 2024-01-08 01:13
    - 1.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

           *   cause if this Future has failed.
           *
           * - And this future *has* failed: This method is called only from handleException (through
           *   getOrInitSeenExceptions). handleException tried to call setException and failed, so
           *   either this Future was cancelled (which we ruled out with the isCancelled check above),
           *   or it had already failed. (It couldn't have completed *successfully* or even had
    Registered: 2024-11-01 12:43
    - Last Modified: 2024-10-25 13:13
    - 16.2K bytes
    - Viewed (0)
Back to top