Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 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 Nov 03 19:28:11 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 08 03:28:17 UTC 2023
    - 37.8K bytes
    - Viewed (0)
  4. 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 Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  5. 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jul 24 01:11:41 UTC 2023
    - 43.9K bytes
    - Viewed (0)
  6. 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jul 24 18:45:14 UTC 2024
    - 95.2K bytes
    - Viewed (0)
  7. docs/pt/docs/advanced/sub-applications.md

    ### Aplicação de nível superior
    
    Primeiro, crie a aplicação principal, de nível superior, **FastAPI**, e suas *operações de rota*:
    
    ```Python hl_lines="3  6-8"
    {!../../docs_src/sub_applications/tutorial001.py!}
    ```
    
    ### Sub-aplicação
    
    Em seguida, crie sua sub-aplicação e suas *operações de rota*.
    
    Essa sub-aplicação é apenas outra aplicação FastAPI padrão, mas esta é a que será "montada":
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. docs/pt/docs/tutorial/dependencies/sub-dependencies.md

    query_or_cookie_extractor(["query_or_cookie_extractor"])
    
    read_query["/items/"]
    
    query_extractor --> query_or_cookie_extractor --> read_query
    ```
    
    ## Utilizando a mesma dependência múltiplas vezes
    
    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 Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  9. 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 Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 13:14:38 UTC 2024
    - 51K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/testdata/s390x.s

    	ADDE	R1, R2                // b9880021
    	SUB	R3, R4                // b9090043
    	SUB	R3, R4, R5            // b9e93054
    	SUB	$8192, R3             // a73be000
    	SUB	$8192, R3, R4         // ec43e00000d9
    	SUBC	R1, R2                // b90b0021
    	SUBC	$1, R1, R2            // ec21ffff00db
    	SUBC	R2, R3, R4            // b9eb2043
    	SUBW	R3, R4                // 1b43
    	SUBW	R3, R4, R5            // b9f93054
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 18 15:49:24 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top