- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 696 for called (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)