Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 641 for toSend (0.19 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. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top