Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 466 for readErr (0.06 sec)

  1. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        connection.setRequestProperty("Accept-Language", "en-US")
        val inputStream = connection.inputStream
        val reader = BufferedReader(InputStreamReader(inputStream, StandardCharsets.UTF_8))
        assertThat(connection.getResponseCode()).isEqualTo(HttpURLConnection.HTTP_OK)
        assertThat(reader.readLine()).isEqualTo("hello world")
        val request = server.takeRequest()
        assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. README.md

    ```
    
    ### Add suggest documents from source of index
    
    ```java
    DocumentReader reader = new ESSourceReader(
        client,
        suggester.settings(),
        "contentIndexName",
        "contentTypeName");
    suggester.indexer().indexFromDocument(reader, 2, 100).getResponse();
    ```
    
    ### Add suggest document from queryLog
    
    ```java
    QueryLog queryLog = new QueryLog("field1:value1", null);
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Jan 19 03:33:49 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  3. internal/auth/credentials.go

    	accessKey, err = GenerateAccessKey(accessKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    	secretKey, err = GenerateSecretKey(secretKeyMaxLen, rand.Reader)
    	if err != nil {
    		return "", "", err
    	}
    	return accessKey, secretKey, nil
    }
    
    // GenerateAccessKey returns a new access key generated randomly using
    // the given io.Reader. If random is nil, crypto/rand.Reader is used.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. internal/hash/errors.go

    }
    
    // SizeTooSmall reader size too small
    type SizeTooSmall struct {
    	Want int64
    	Got  int64
    }
    
    func (e SizeTooSmall) Error() string {
    	return fmt.Sprintf("Size small: got %d, want %d", e.Got, e.Want)
    }
    
    // SizeTooLarge reader size too large
    type SizeTooLarge struct {
    	Want int64
    	Got  int64
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 15 21:08:54 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  5. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt

          }
    
          override fun fromDer(reader: DerReader): Long {
            val peekHeader =
              reader.peekHeader()
                ?: throw ProtocolException("expected time but was exhausted at $reader")
    
            return when {
              peekHeader.tagClass == Adapters.UTC_TIME.tagClass &&
                peekHeader.tag == Adapters.UTC_TIME.tag -> {
                Adapters.UTC_TIME.fromDer(reader)
              }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/TestCharSource.java

     * limitations under the License.
     */
    
    package com.google.common.io;
    
    import static java.nio.charset.StandardCharsets.UTF_8;
    
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.Reader;
    
    /**
     * A char source for testing that has configurable options.
     *
     * @author Colin Decker
     */
    public class TestCharSource extends CharSource implements TestStreamSupplier {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/SourceSinkFactories.java

        }
    
        @Override
        public String getSinkContents() throws IOException {
          Path file = getPath();
          try (Reader reader = java.nio.file.Files.newBufferedReader(file, UTF_8)) {
            StringBuilder builder = new StringBuilder();
            for (int c = reader.read(); c != -1; c = reader.read()) {
              builder.append((char) c);
            }
            return builder.toString();
          }
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/BaseEncoding.java

      }
    
      /**
       * Returns an {@code InputStream} that decodes base-encoded input from the specified {@code
       * Reader}. The returned stream throws a {@link DecodingException} upon decoding-specific errors.
       */
      @J2ktIncompatible
      @GwtIncompatible // Reader,InputStream
      public abstract InputStream decodingStream(Reader reader);
    
      /**
       * Returns a {@code ByteSource} that reads base-encoded bytes from the specified {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  10. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/DefaultToolchainsReader.java

                        e.getLocation().getColumnNumber(),
                        e);
            }
        }
    
        @Override
        public PersistedToolchains read(Reader input, Map<String, ?> options) throws IOException {
            Objects.requireNonNull(input, "input cannot be null");
    
            try (Reader in = input) {
                InputSource source = (InputSource) options.get(InputSource.class.getName());
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top