- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 379 for queued (0.06 sec)
-
src/main/java/jcifs/smb1/smb1/SID.java
* expired because under normal circumstances SID information never changes. *Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 31.5K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
docs/pt/docs/tutorial/dependencies/dependencies-with-yield.md
/// /// tip | Dica Se você levantar qualquer exceção no código da *função de operação de rota*, ela será passada para as dependências com `yield`, incluindo `HTTPException`. Na maioria dos casos, você vai querer relançar essa mesma exceção ou uma nova a partir da dependência com `yield` para garantir que ela seja tratada adequadamente. /// ## Saída antecipada e `scope` { #early-exit-and-scope }Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 14.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* * <ol> * <li>Update the {@link #servicesByState()} * <li>Update the {@link #startupTimers} * <li>Based on the new state queue listeners to run * <li>Run the listeners (outside of the lock) * </ol> */ void transitionService(Service service, State from, State to) { checkNotNull(service);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 33.2K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* * <ol> * <li>Update the {@link #servicesByState()} * <li>Update the {@link #startupTimers} * <li>Based on the new state queue listeners to run * <li>Run the listeners (outside of the lock) * </ol> */ void transitionService(Service service, State from, State to) { checkNotNull(service);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Sep 22 17:49:12 UTC 2025 - 32.9K bytes - Viewed (0) -
docs/es/docs/advanced/path-operation-advanced-configuration.md
Por ejemplo, podrías decidir leer y validar el request con tu propio código, sin usar las funcionalidades automáticas de FastAPI con Pydantic, pero aún podrías querer definir el request en el esquema de OpenAPI. Podrías hacer eso con `openapi_extra`: {* ../../docs_src/path_operation_advanced_configuration/tutorial006_py39.py hl[19:36, 39:40] *}Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 8.3K bytes - Viewed (0) -
internal/event/target/postgresql.go
var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-postgresql-"+id) queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of PostgreSQL `%s`: %w", id, err) } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 13.3K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
server.enqueue( MockResponse .Builder() .body("enqueued in the background") .build(), ) }.start() val connection = server.url("/").toUrl().openConnection() val reader = BufferedReader(InputStreamReader(connection!!.getInputStream(), UTF_8)) assertThat(reader.readLine()).isEqualTo("enqueued in the background") } @Test fun nonHexadecimalChunkSize() {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Aug 03 22:38:00 UTC 2025 - 28K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessConfig.java
* Get the value for the key 'logging.search.max.queue.size'. <br> * The value is, e.g. 10000 <br> * comment: Maximum queue size for search logging. * @return The value of found property. (NotNull: if not found, exception but basically no way) */ String getLoggingSearchMaxQueueSize(); /** * Get the value for the key 'logging.search.max.queue.size' as {@link Integer}. <br>
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 525.7K bytes - Viewed (2) -
cmd/sftp-server-driver.go
_ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0)