Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 111 for subs (0.02 sec)

  1. internal/pubsub/pubsub.go

    	go func() {
    		<-doneCh
    
    		ps.Lock()
    		defer ps.Unlock()
    		var remainTypes Mask
    		for i, s := range ps.subs {
    			if s == sub {
    				ps.subs = append(ps.subs[:i], ps.subs[i+1:]...)
    			} else {
    				remainTypes.Merge(s.types)
    			}
    		}
    		atomic.StoreUint64(&ps.types, uint64(remainTypes))
    		atomic.AddInt32(&ps.numSubscribers, -1)
    	}()
    
    	return nil
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub_test.go

    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 {
    		t.Fatalf("expected 2 subscribers")
    	}
    }
    
    func TestNumSubscribersMask(t *testing.T) {
    	ps := New[Maskable, Mask](2)
    	ch1 := make(chan Maskable, 1)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/testdata/arm64error.s

    	SUBS	$0xff, R6, RSP                                   // ERROR "illegal destination register"
    	SUBS	$0xffff0, R6, RSP                                // ERROR "illegal destination register"
    	SUBS	$0x1000100010001000, R6, RSP                     // ERROR "illegal destination register"
    	SUBS	$0x10001000100011, R6, RSP                       // ERROR "illegal destination register"
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Oct 14 19:00:00 UTC 2025
    - 38.4K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SIDTest.java

        private static rpc.sid_t buildSidT(byte revision, byte[] identAuth, int... subs) {
            rpc.sid_t s = new rpc.sid_t();
            s.revision = revision;
            s.sub_authority_count = (byte) subs.length;
            s.identifier_authority = Arrays.copyOf(identAuth, 6);
            s.sub_authority = Arrays.copyOf(subs, subs.length);
            return s;
        }
    
        @Nested
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

                terminal = ft.getTerminal();
            }
            List<String> subs = new ArrayList<>();
            subs.add("type=" + terminal.getType());
            if (terminal instanceof TerminalExt te) {
                subs.add("provider=" + te.getProvider().name());
            }
            if (terminal instanceof AbstractPosixTerminal pt) {
                subs.add("pty=" + pt.getPty().getClass().getName());
            }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Oct 28 13:01:07 UTC 2025
    - 43.2K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/testdata/arm64enc.s

    	SUBS R21.UXTX<<2, R27, R4                  // 646b35eb
    	SUBSW $(44<<12), R6, R9                    // SUBSW $180224, R6, R9         // c9b04071
    	SUBS $(1804<<12), R13, R9                  // SUBS $7389184, R13, R9        // a9315cf1
    	SUBSW R22->28, R6, R7                      // c770966b
    	SUBSW R22>>28, R6, R7                      // c770566b
    	SUBS R26<<15, R6, R16                      // d03c1aeb
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Jul 24 01:11:41 UTC 2023
    - 43.9K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/asm/testdata/arm64.s

    	SUB	$0x000aaa, R2, R3               // SUB $2730, R2, R3                      // 43a82ad1
    	SUB	$0x000aaa, R2                   // SUB $2730, R2                          // 42a82ad1
    	SUB	$0xaaa000, R2, R3               // SUB $11182080, R2, R3                  // 43a86ad1
    	SUB	$0xaaa000, R2                   // SUB $11182080, R2                      // 42a86ad1
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Mon Nov 10 17:34:13 UTC 2025
    - 96.1K bytes
    - Viewed (0)
  8. docs/pt/docs/advanced/sub-applications.md

    ### Aplicação de nível superior { #top-level-application }
    
    Primeiro, crie a aplicação principal, de nível superior, **FastAPI**, e suas *operações de rota*:
    
    {* ../../docs_src/sub_applications/tutorial001_py39.py hl[3, 6:8] *}
    
    ### Sub-aplicação { #sub-application }
    
    Em seguida, crie sua sub-aplicação e suas *operações de rota*.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  9. docs/pt/docs/tutorial/dependencies/sub-dependencies.md

    read_query["/items/"]
    
    query_extractor --> query_or_cookie_extractor --> read_query
    ```
    
    ## Utilizando a mesma dependência múltiplas vezes { #using-the-same-dependency-multiple-times }
    
    Se uma de suas dependências é declarada várias vezes para a mesma *operação de rota*, por exemplo, múltiplas dependências com uma mesma subdependência, o **FastAPI** irá chamar essa subdependência uma única vez para cada requisição.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/testdata/ppc64.s

    	SUBMEVCC R3, R4                 // 7c8305d1
    	SUBV R3, R4, R5                 // 7ca32450
    	SUBE R3, R4, R5                 // 7ca32110
    	SUBECC R3, R4, R5               // 7ca32111
    	SUBEV R3, R4, R5                // 7ca32510
    	SUBEVCC R3, R4, R5              // 7ca32511
    	SUBC R3, $65536, R4             // 3fe00001600000007c83f810
    	SUBC R3, $65537, R4             // 3fe0000163ff00017c83f810
    
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Nov 21 18:27:17 UTC 2024
    - 51.7K bytes
    - Viewed (0)
Back to top