Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 367 for toSend (0.07 sec)

  1. internal/grid/connection.go

    		}
    
    		toSend = merged[:0]
    		m := message{Op: OpMerged, Seq: uint32(len(queue))}
    		var err error
    		toSend, err = m.MarshalMsg(toSend)
    		if err != nil {
    			gridLogIf(ctx, fmt.Errorf("msg.MarshalMsg: %w", err))
    			return
    		}
    		// Append as byte slices.
    		for _, q := range queue {
    			toSend = msgp.AppendBytes(toSend, q)
    			PutByteBuffer(q)
    		}
    		queue = queue[:0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. internal/grid/benchmark_test.go

    				for i := 0; i < responses; i++ {
    					toSend := GetByteBuffer()[:0]
    					toSend = append(toSend, byte(i))
    					toSend = append(toSend, payload...)
    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. internal/grid/muxserver.go

    }
    
    // sendResponses will send responses to the client.
    func (m *muxServer) sendResponses(ctx context.Context, toSend <-chan []byte, c *Connection, handlerErr *atomic.Pointer[RemoteErr], outBlock <-chan struct{}) {
    	for {
    		// Process outgoing message.
    		var payload []byte
    		var ok bool
    		select {
    		case payload, ok = <-toSend:
    		case <-ctx.Done():
    			return
    		}
    		select {
    		case <-ctx.Done():
    			return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/dict/kuromoji/KuromojiFileTest.java

            List<KuromojiItem> itemList = new ArrayList<>();
            itemList.add(new KuromojiItem(1, "token1", "seg1", "reading1", "pos1"));
            itemList.add(new KuromojiItem(2, "token2", "seg2", "reading2", "pos2"));
            itemList.add(new KuromojiItem(3, "token3", "seg3", "reading3", "pos3"));
            kuromojiFile.kuromojiItemList = itemList;
        }
    
        public void test_selectList() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      public void testAssignableClassToType() {
        TypeToken<List<String>> tokenL = new TypeToken<List<String>>() {};
        assertTrue(tokenL.isSupertypeOf(StringList.class));
        assertFalse(tokenL.isSupertypeOf(List.class));
    
        TypeToken<First<String>> tokenF = new TypeToken<First<String>>() {};
        assertTrue(tokenF.isSupertypeOf(ConcreteIS.class));
        assertFalse(tokenF.isSupertypeOf(ConcreteSI.class));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 21:13:09 UTC 2024
    - 89.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      public void testAssignableClassToType() {
        TypeToken<List<String>> tokenL = new TypeToken<List<String>>() {};
        assertTrue(tokenL.isSupertypeOf(StringList.class));
        assertFalse(tokenL.isSupertypeOf(List.class));
    
        TypeToken<First<String>> tokenF = new TypeToken<First<String>>() {};
        assertTrue(tokenF.isSupertypeOf(ConcreteIS.class));
        assertFalse(tokenF.isSupertypeOf(ConcreteSI.class));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 21:13:09 UTC 2024
    - 89.1K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/helper/AccessTokenHelperTest.java

            List<String> tokens = new ArrayList<String>();
            for (int i = 0; i < NUM; i++) {
                tokens.add(accessTokenHelper.generateAccessToken());
            }
            for (int i = 0; i < NUM; i++) {
                assertFalse(tokens.get(i).isEmpty());
                for (int j = i + 1; j < NUM; j++) {
                    assertFalse(tokens.get(i).equals(tokens.get(j)));
                }
            }
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/security/oauth2-jwt.md

    {!> ../../docs_src/security/tutorial004.py!}
    ```
    
    ////
    
    ## Update the dependencies
    
    Update `get_current_user` to receive the same token as before, but this time, using JWT tokens.
    
    Decode the received token, verify it, and return the current user.
    
    If the token is invalid, return an HTTP error right away.
    
    //// tab | Python 3.10+
    
    ```Python hl_lines="90-107"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 26 11:45:10 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  9. docs/de/docs/tutorial/security/oauth2-jwt.md

    ```
    
    ////
    
    ## Die Abhängigkeiten aktualisieren
    
    Aktualisieren Sie `get_current_user`, um den gleichen Token wie zuvor zu erhalten, dieses Mal jedoch unter Verwendung von JWT-Tokens.
    
    Dekodieren Sie den empfangenen Token, validieren Sie ihn und geben Sie den aktuellen Benutzer zurück.
    
    Wenn der Token ungültig ist, geben Sie sofort einen HTTP-Fehler zurück.
    
    //// tab | Python 3.10+
    
    ```Python hl_lines="89-106"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 15K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/lex/input.go

    	var tokens []Token
    	for _, tok := range macro.tokens {
    		if tok.ScanToken != scanner.Ident {
    			tokens = append(tokens, tok)
    			continue
    		}
    		substitution := actuals[tok.text]
    		if substitution == nil {
    			tokens = append(tokens, tok)
    			continue
    		}
    		tokens = append(tokens, substitution...)
    	}
    	in.Push(NewSlice(in.Base(), in.Line(), tokens))
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
Back to top