- Sort Score
- Num 10 results
- Language All
Results 351 - 360 of 444 for Queues (0.04 seconds)
-
docs/es/docs/advanced/openapi-callbacks.md
Observa que no estás pasando el router en sí (`invoices_callback_router`) a `callback=`, sino el atributo `.routes`, como en `invoices_callback_router.routes`. /// ### Revisa la documentación { #check-the-docs } Ahora puedes iniciar tu aplicación e ir a [http://127.0.0.1:8000/docs](http://127.0.0.1:8000/docs). Verás tu documentación incluyendo una sección de "Callbacks" para tu *path operation* que muestra cómo debería verse la *API externa*:Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java
/** Available send credits for flow control */ protected final AtomicInteger sendCredits; /** Available receive credits for flow control */ protected final AtomicInteger receiveCredits; /** Queue of pending RDMA work requests */ protected final BlockingQueue<RdmaWorkRequest> pendingRequests; // Connection state /** Current connection state */ protected volatile RdmaConnectionState state;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 24 00:12:28 GMT 2025 - 8.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java
} } /** * Stores a failure URL with error information for later analysis. * * @param crawlerContext the crawler context * @param urlQueue the URL queue containing the failed URL * @param errorName the name/type of the error * @param e the throwable that caused the failure * @return the stored FailureUrl entity */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 8.3K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
import java.util.Iterator; import java.util.List; import java.util.ListIterator; import java.util.Locale; import java.util.Map; import java.util.NavigableMap; import java.util.NavigableSet; import java.util.Queue; import java.util.Random; import java.util.Set; import java.util.SortedMap; import java.util.SortedSet; import java.util.UUID; import java.util.concurrent.BlockingDeque;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 17:50:58 GMT 2025 - 20.9K bytes - Click Count (0) -
internal/logger/logrotate.go
// or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary. // Write is non-blocking, if the writer's queue is not full. // Write is blocking otherwise. func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 5.8K bytes - Click Count (0) -
src/main/webapp/css/admin/respond.min.js
a.ActiveXObject("Microsoft.XMLHTTP")}return function(){return b}}(),f=function(a,b){var c=e();c&&(c.open("GET",a,!0),c.onreadystatechange=function(){4!==c.readyState||200!==c.status&&304!==c.status||b(c.responseText)},4!==c.readyState&&c.send(null))};if(c.ajax=f,c.queue=d,c.regex={media:/@media[^\{]+\{([^\{\}]*\{[^\}\{]*\})+/gi,keyframes:/@(?:\-(?:o|moz|webkit)\-)?keyframes[^\{]+\{(?:[^\{\}]*\{[^\}\{]*\})+[^\}]*\}/gi,urls:/(url\()['"]?([^\/\)'"][^:\)'"]+)['"]?(\))/g,findStyles:/@media *([^\{]+)\{([\S\s]+?)$/,only...
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Oct 08 12:14:13 GMT 2015 - 4.3K bytes - Click Count (0) -
CODE_OF_CONDUCT.md
## Conflict Resolution Conflicts in an open source project can take many forms, from someone having a bad day and using harsh and hurtful language in the issue queue, to more serious instances such as sexist/racist statements or threats of violence, and everything in between. If the behavior is threatening or harassing, or for other reasons requires immediate escalation, please see below.
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Fri Feb 05 18:43:16 GMT 2021 - 5.2K bytes - Click Count (0) -
internal/event/target/mqtt.go
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 MQTT `%s`: %w", id, err) } } target := &MQTTTarget{ id: event.TargetID{ID: id, Name: "mqtt"}, args: args, store: queueStore, quitCh: make(chan struct{}),
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// contract. // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could // drop the contract on the method that enforces this queue like behavior since depending on it // is likely to be a bug anyway. // N.B. All writes to the list and the next pointers must have happened before the aboveCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 6.9K bytes - Click Count (0) -
internal/event/target/nsq.go
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 NSQ `%s`: %w", id, err) } } target := &NSQTarget{ id: event.TargetID{ID: id, Name: "nsq"}, args: args, loggerOnce: loggerOnce, store: queueStore,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0)