Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 351 - 360 of 444 for Queues (0.15 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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 above
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  10. 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)
Back to Top