- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 367 for toSend (0.07 sec)
-
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) -
internal/grid/benchmark_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
src/test/java/org/codelibs/fess/helper/AccessTokenHelperTest.java
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.1K bytes - Viewed (0) -
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) -
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) -
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)