- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 641 for toSend (0.19 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) -
docs/sts/custom-token-identity.go
"net/url" "time" "github.com/minio/minio-go/v7" cr "github.com/minio/minio-go/v7/pkg/credentials" ) var ( // LDAP integrated Minio endpoint stsEndpoint string // token to use with AssumeRoleWithCustomToken token string // Role ARN to use roleArn string // Display credentials flag displayCreds bool // Credential expiry duration expiryDuration time.Duration // Bucket to list
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 27 00:58:09 UTC 2022 - 3.4K bytes - Viewed (0) -
docs/sts/custom-token-identity.md
| Version | String | Yes | Value must be `2011-06-15` | | Token | String | Yes | Token to be authenticated by identity plugin | | RoleArn | String | Yes | Must match the Role ARN generated for the identity plugin |
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 27 00:58:09 UTC 2022 - 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)