Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for mapTable (1.61 sec)

  1. internal/pubsub/pubsub_test.go

    func TestMultiPubSub(t *testing.T) {
    	ps := New[Maskable, Maskable](2)
    	ch1 := make(chan Maskable, 1)
    	ch2 := make(chan Maskable, 1)
    	doneCh := make(chan struct{})
    	defer close(doneCh)
    	if err := ps.Subscribe(MaskAll, ch1, doneCh, func(entry Maskable) bool { return true }); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, func(entry Maskable) bool { return true }); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub.go

    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    	ch     chan T
    	types  Mask
    	filter func(entry T) bool
    }
    
    // PubSub holds publishers and subscribers
    type PubSub[T Maskable, M Maskable] struct {
    	// atomics, keep at top:
    	types          uint64
    	numSubscribers int32
    	maxSubscribers int32
    
    	// not atomics:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. internal/pubsub/mask.go

    func (t *Mask) MergeMaskable(other Maskable) {
    	*t |= Mask(other.Mask())
    }
    
    // SetIf will add other if b is true.
    func (t *Mask) SetIf(b bool, other Mask) {
    	if b {
    		*t |= other
    	}
    }
    
    // Mask returns the mask as a uint64.
    func (t Mask) Mask() uint64 {
    	return uint64(t)
    }
    
    // Maskable implementations must return their mask as a 64 bit uint.
    type Maskable interface {
    	Mask() uint64
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  4. .gitattributes

    # line endings. This produces predictable results in different environments.
    #
    # Windows users contributing to Go will need to use a modern version
    # of git and editors capable of LF line endings.
    #
    # Windows .bat files are known to have multiple bugs when run with LF
    # endings, and so they are checked in with CRLF endings, with a test
    # in test/winbatch.go to catch problems. (See golang.org/issue/37791.)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Jun 08 15:31:43 UTC 2020
    - 639 bytes
    - Viewed (0)
  5. internal/http/listener.go

    	"net"
    	"slices"
    	"syscall"
    	"time"
    
    	"github.com/minio/minio/internal/deadlineconn"
    )
    
    type acceptResult struct {
    	conn net.Conn
    	err  error
    	lidx int
    }
    
    // httpListener - HTTP listener capable of handling multiple server addresses.
    type httpListener struct {
    	opts        TCPOptions
    	listeners   []net.Listener    // underlying TCP listeners.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

       */
      fun cancel()
    
      /**
       * Carries an exchange. This is usually a connection, but it could also be a connect plan for
       * CONNECT tunnels. Note that CONNECT tunnels are significantly less capable than connections.
       */
      interface Carrier {
        val route: Route
    
        fun trackFailure(
          call: RealCall,
          e: IOException?,
        )
    
        fun noNewExchanges()
    
        fun cancel()
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Jul 29 21:11:09 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  7. docs/fr/docs/deployment/versions.md

    des changements rétrocompatibles.
    
    /// tip | Astuce
    
    Le "PATCH" est le dernier chiffre, par exemple, dans `0.2.3`, la version PATCH est `3`.
    
    ///
    
    Donc, vous devriez être capable d'épingler une version comme suit :
    
    ```txt
    fastapi>=0.45.0,<0.46.0
    ```
    
    Les changements non rétrocompatibles et les nouvelles fonctionnalités sont ajoutés dans les versions "MINOR".
    
    /// tip | Astuce
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. impl/maven-core/src/site/apt/getting-to-container-configured-mojos.apt

      very little value to the container. Things like ${project.build.resources}
      are not resolved, and result in a type mismatch for the member injection.
    
      We need a replacement for DefaultExpressionEvaluator that is capable of
      traversing an object graph and extracting Object values, not just Strings.
    
    * ComponentConfigurator
    
      Currently, the container uses BasicComponentConfigurator, to configure
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  9. docs/en/docs/advanced/dataclasses.md

        In this case, it's a list of `Item` dataclasses.
    
    6. Here we are returning a dictionary that contains `items` which is a list of dataclasses.
    
        FastAPI is still capable of <abbr title="converting the data to a format that can be transmitted">serializing</abbr> the data to JSON.
    
    7. Here the `response_model` is using a type annotation of a list of `Author` dataclasses.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Fri Dec 26 10:43:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  10. docs/fr/docs/tutorial/query-params.md

    {* ../../docs_src/query_params/tutorial002.py hl[9] *}
    
    Ici, le paramètre `q` sera optionnel, et aura `None` comme valeur par défaut.
    
    /// check | Remarque
    
    On peut voir que **FastAPI** est capable de détecter que le paramètre de chemin `item_id` est un paramètre de chemin et que `q` n'en est pas un, c'est donc un paramètre de requête.
    
    ///
    
    /// note
    
    **FastAPI** saura que `q` est optionnel grâce au `=None`.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 5.6K bytes
    - Viewed (0)
Back to top