Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 1,476 for leader (0.04 seconds)

  1. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        Reader reader = new StringReader("abcde");
        assertThrows(EOFException.class, () -> CharStreams.skipFully(reader, 6));
      }
    
      public void testSkipFully() throws IOException {
        String testString = "abcdef";
        Reader reader = new StringReader(testString);
    
        assertEquals(testString.charAt(0), reader.read());
        CharStreams.skipFully(reader, 1);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/io/CharStreamsTest.java

        Reader reader = new StringReader("abcde");
        assertThrows(EOFException.class, () -> CharStreams.skipFully(reader, 6));
      }
    
      public void testSkipFully() throws IOException {
        String testString = "abcdef";
        Reader reader = new StringReader(testString);
    
        assertEquals(testString.charAt(0), reader.read());
        CharStreams.skipFully(reader, 1);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  3. cmd/storage-rest-server.go

    // has been used.
    // The returned reader contains the payload.
    func waitForHTTPResponse(respBody io.Reader) (io.Reader, error) {
    	reader := bufio.NewReader(respBody)
    	for {
    		b, err := reader.ReadByte()
    		if err != nil {
    			return nil, err
    		}
    		// Check if we have a response ready or a filler byte.
    		switch b {
    		case 0:
    			return reader, nil
    		case 1:
    			errorText, err := io.ReadAll(reader)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  4. compat/maven-model/src/main/java/org/apache/maven/model/io/xpp3/MavenXpp3ReaderEx.java

        @Override
        public Model read(Reader reader, boolean strict, InputSource source) throws IOException, XmlPullParserException {
            return super.read(reader, strict, source);
        }
    
        @Override
        public Model read(Reader reader, boolean strict) throws IOException, XmlPullParserException {
            return super.read(reader, strict);
        }
    
        @Override
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2.8K bytes
    - Click Count (0)
  5. internal/grid/connection.go

    	)
    
    	bts := ww.tmp[:]
    	if f.Header.Fin {
    		bts[0] |= bit0
    	}
    	bts[0] |= f.Header.Rsv << 4
    	bts[0] |= byte(f.Header.OpCode)
    
    	var n int
    	switch {
    	case f.Header.Length <= len7:
    		bts[1] = byte(f.Header.Length)
    		n = 2
    
    	case f.Header.Length <= len16:
    		bts[1] = 126
    		binary.BigEndian.PutUint16(bts[2:4], uint16(f.Header.Length))
    		n = 4
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  6. internal/crypto/header_test.go

    		if Requested(test.Header) != got {
    			// Test if result matches.
    			t.Errorf("Requested mismatch, want %v, got %v", Requested(test.Header), got)
    		}
    		got = got && SSEC.IsRequested(test.Header)
    		if got != test.Expected {
    			t.Errorf("SSE-C: Test %d: Wanted %v but got %v", i, test.Expected, got)
    		}
    	}
    }
    
    var kmsIsRequestedTests = []struct {
    	Header   http.Header
    	Expected bool
    }{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jul 13 14:52:15 GMT 2022
    - 21.4K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb2/Smb2TransformHeaderTest.java

        }
    
        @Test
        @DisplayName("Should create transform header with correct size")
        void testTransformHeaderSize() {
            // When
            int headerSize = transformHeader.size();
    
            // Then
            assertEquals(52, headerSize); // SMB2 Transform Header is 52 bytes
        }
    
        // Note: SMB2 Transform Header doesn't have a protocol ID field
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  8. cmd/xl-storage-format-v2.go

    					case !strict && ver.header.matchesNotStrict(latest.header):
    						latestCount++
    					default:
    						latestCount = 1
    					}
    					latest = ver
    					continue
    				}
    
    				// Mismatch, but older.
    				if latestCount > 0 && !strict && ver.header.matchesNotStrict(latest.header) {
    					latestCount++
    					continue
    				}
    				if latestCount > 0 && ver.header.VersionID == latest.header.VersionID {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  9. src/main/java/org/codelibs/core/io/CopyUtil.java

        }
    
        /**
         * Wraps the reader with a {@link BufferedReader} if necessary.
         *
         * @param reader the reader
         * @return the wrapped reader
         */
        protected static Reader wrap(final Reader reader) {
            if (reader instanceof BufferedReader) {
                return reader;
            }
            if (reader instanceof StringReader) {
                return reader;
            }
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  10. api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlReaderRequest.java

                this.inputStream = inputStream;
                return this;
            }
    
            public XmlReaderRequestBuilder reader(Reader reader) {
                this.reader = reader;
                return this;
            }
    
            public XmlReaderRequestBuilder transformer(Transformer transformer) {
                this.transformer = transformer;
                return this;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Aug 29 12:46:27 GMT 2025
    - 6.8K bytes
    - Click Count (0)
Back to Top