- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 176 for COMPLETED (0.22 sec)
-
cmd/bucket-replication-utils_test.go
expectedCompletedSize: 249, expectedReplicationStatusInternal: "arn1=COMPLETED;", expectedReplicationStatus: replication.Completed, expectedOpType: replication.ObjectReplicationType, expectedAction: replicateAll, }, { // 3. replication completed to single target; failed to another name: "replication completed to single target", tgtInfos: []replicatedTargetInfo{ {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 08 20:27:40 GMT 2023 - 9.3K bytes - Viewed (0) -
tests/test_tutorial/test_async_sql_databases/test_tutorial001.py
with TestClient(app) as client: note = {"text": "Foo bar", "completed": False} response = client.post("/notes/", json=note) assert response.status_code == 200, response.text data = response.json() assert data["text"] == note["text"] assert data["completed"] == note["completed"] assert "id" in data response = client.get("/notes/")
Python - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Wed Oct 18 12:36:40 GMT 2023 - 6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SpnegoContext.java
} else if ( targ.getResult() != NegTokenTarg.ACCEPT_COMPLETED ) { throw new SmbException("SPNEGO negotiation did not complete"); } verifyMechListMIC(targ.getMechanismListMIC()); this.completed = true; return null; } if ( inputToken == null ) { return initialToken();
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Mon Jan 04 04:18:31 GMT 2021 - 14.8K bytes - Viewed (0) -
docs_src/async_sql_databases/tutorial001.py
sqlalchemy.Column("completed", sqlalchemy.Boolean), ) engine = sqlalchemy.create_engine( DATABASE_URL, connect_args={"check_same_thread": False} ) metadata.create_all(engine) class NoteIn(BaseModel): text: str completed: bool class Note(BaseModel): id: int text: str completed: bool app = FastAPI()
Python - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Thu Mar 26 19:09:53 GMT 2020 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
super.close() complete(null) } catch (e: IOException) { throw complete(e) } } private fun <E : IOException?> complete(e: E): E { if (completed) return e completed = true return bodyComplete(bytesReceived, responseDone = false, requestDone = true, e = e) } } /** A response body that fires events when it completes. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
cmd/bucket-replication-utils.go
if len(ri.Targets) == 0 { return replication.StatusType("") } completed := 0 for _, v := range ri.Targets { switch v.ReplicationStatus { case replication.Failed: return replication.Failed case replication.Completed: completed++ } } if completed == len(ri.Targets) { return replication.Completed } return replication.Pending }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
assertTrue(queue.offer("blocksPutCallsUntilRemoved")); this.completed = new Completion(countdownInMillis); scheduleEnableWrites(this.queue, countdownInMillis); } /** Perform a {@code put} and assert that operation completed in the expected timeframe. */ void putSuccessfully() { putUninterruptibly(queue, ""); completed.assertCompletionExpected(); assertEquals("", queue.peek()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
assertTrue(queue.offer("blocksPutCallsUntilRemoved")); this.completed = new Completion(countdownInMillis); scheduleEnableWrites(this.queue, countdownInMillis); } /** Perform a {@code put} and assert that operation completed in the expected timeframe. */ void putSuccessfully() { putUninterruptibly(queue, ""); completed.assertCompletionExpected(); assertEquals("", queue.peek()); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 30.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} /** Transition to the COMPLETED state and set the value. */ boolean set(@Nullable V v) { return complete(v, null, COMPLETED); } /** Transition to the COMPLETED state and set the exception. */ boolean setException(Throwable t) { return complete(null, t, COMPLETED); } /** Transition to the CANCELLED or INTERRUPTED state. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} /** Transition to the COMPLETED state and set the value. */ boolean set(@Nullable V v) { return complete(v, null, COMPLETED); } /** Transition to the COMPLETED state and set the exception. */ boolean setException(Throwable t) { return complete(null, t, COMPLETED); } /** Transition to the CANCELLED or INTERRUPTED state. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0)