Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for mapTable (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Aug 14 17:11:51 GMT 2024
    - 5.8K bytes
    - Click Count (0)
  2. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 05 21:45:49 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  3. 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:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (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.)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 08 15:31:43 GMT 2020
    - 639 bytes
    - Click Count (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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (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()
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  7. docs/fr/docs/advanced/dataclasses.md

        Dans ce cas, il s'agit d'une liste de dataclasses `Item`.
    
    6. Ici, nous renvoyons un dictionnaire qui contient `items`, qui est une liste de dataclasses.
    
        FastAPI est toujours capable de <dfn title="convertir les données dans un format pouvant être transmis">sérialiser</dfn> les données en JSON.
    
    7. Ici, `response_model` utilise une annotation de type correspondant à une liste de dataclasses `Author`.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/HandshakeCertificates.kt

         * fail. Use a custom [HostnameVerifier] to ignore such problems.
         *
         * Other TLS features are still used but provide no security benefits in absence of the above
         * gaps. For example, an insecure TLS connection is capable of negotiating HTTP/2 with ALPN and
         * it also has a regular-looking handshake.
         *
         * **This feature is not supported on Android API levels less than 24.** Prior releases lacked
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/platform/Platform.kt

        val isAndroid: Boolean
          get() = PlatformRegistry.isAndroid
    
        /** Attempt to match the host runtime to a capable Platform implementation. */
        private fun findPlatform(): Platform = PlatformRegistry.findPlatform()
    
        /**
         * Returns the concatenation of 8-bit, length prefixed protocol names.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  10. docs/fr/docs/tutorial/body.md

    ## Corps de la requête + paramètres de chemin { #request-body-path-parameters }
    
    Vous pouvez déclarer des paramètres de chemin et un corps de requête pour la même *chemin d'accès*.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 7.8K bytes
    - Click Count (0)
Back to Top