atrule - Code Search

okhttp/src/main/kotlin/okhttp3/RequestBody.kt

   * writing.
   *
   * [grpc]: https://github.com/grpc/grpc/blob/master/doc/PROTOCOL-HTTP2.md
   */
  open fun isDuplex(): Boolean = commonIsDuplex()

  /**
   * Returns true if this body expects at most one call to [writeTo] and can be transmitted
   * at most once. This is typically used when writing the request body is destructive and it is not

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Thu Jan 25 14:41:37 UTC 2024

- 9.6K bytes

- Viewed (0)

github.com/codelibs/curl4j

src/main/java/org/codelibs/curl/CurlRequest.java

                    connectionBuilder.accept(this, connection);
                }

                if (body != null) {
                    logger.fine(() -> ">>> " + body);
                    connection.setDoOutput(true);
                    try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(connection.getOutputStream(), encoding))) {
                        writer.write(body);
                        writer.flush();

Registered: Thu Oct 31 02:32:13 UTC 2024

- Last Modified: Sun Feb 12 12:21:25 UTC 2023

- 12.3K bytes

- Viewed (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java

    Method method;
    try {
      method = extractMethod(test);
    } catch (IllegalArgumentException e) {
      logger.finer(Platform.format("%s: including by default: %s", test, e.getMessage()));
      return true;
    }
    if (suppressedTests.contains(method)) {
      logger.finer(Platform.format("%s: excluding because it was explicitly suppressed.", test));
      return false;
    }
    TesterRequirements requirements;

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Oct 30 16:15:19 UTC 2024

- 10.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java

 * SMB server addressed by the URL parameter. See {@link jcifs.smb1.smb1.SmbFile}
 * for a detailed description and examples of the smb URL syntax. If the
 * second argument is <code>true</code>, then bytes will be written to the
 * end of the file rather than the beginning.
 *
 * @param url An smb URL string representing the file to write to
 * @param append Append to the end of file
 */

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 9.2K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java

        LocalArtifactResult result = new LocalArtifactResult(request);
        if (file.isFile()) {
            result.setFile(file);
            result.setAvailable(true);
        }

        return result;
    }

    public LocalMetadataResult find(RepositorySystemSession session, LocalMetadataRequest request) {
        Metadata metadata = request.getMetadata();

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 12.2K bytes

- Viewed (0)

github.com/minio/minio

internal/config/dns/etcd_dns.go

	srvRecords := map[string][]SrvRecord{}
	for _, domainName := range c.domainNames {
		key := msgPath(fmt.Sprintf("%s.", domainName), c.prefixPath)
		records, err := c.list(key+etcdPathSeparator, true)
		if err != nil {
			return srvRecords, err
		}
		for _, record := range records {
			if record.Key == "" {
				continue
			}
			srvRecords[record.Key] = append(srvRecords[record.Key], record)
		}
	}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu Sep 26 15:03:08 UTC 2024

- 8K bytes

- Viewed (0)

github.com/minio/minio

internal/mountinfo/mountinfo_linux_test.go

		return false
	}
	return true
}

// Checks if two string slices are equal.
func slicesEqual(a, b []string) bool {
	if len(a) != len(b) {
		return false
	}
	for i := range a {
		if a[i] != b[i] {
			return false
		}
	}
	return true

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu Jan 18 07:03:17 UTC 2024

- 7.3K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/discovery/v1/generated.proto

  // according to whatever system is managing the endpoint. A nil value
  // indicates an unknown state. In most cases consumers should interpret this
  // unknown state as ready. For compatibility reasons, ready should never be
  // "true" for terminating endpoints, except when the normal readiness
  // behavior is being explicitly overridden, for example when the associated
  // Service has set the publishNotReadyAddresses flag.
  // +optional

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Mon Mar 11 18:43:24 UTC 2024

- 8K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/crawler/transformer/FessXpathTransformerTest.java

    }

    private void setValueToObject(Object obj, String name, Object value) {
        Field field = ClassUtil.getDeclaredField(obj.getClass(), name);
        field.setAccessible(true);
        FieldUtil.set(field, obj, value);
    }

    public void test_pruneNode() throws Exception {
        final String data = "<html><body><br/><script>foo</script><noscript>bar</noscript></body></html>";

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Oct 24 13:01:38 UTC 2024

- 41.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CallKotlinTest.kt

@Timeout(30)
class CallKotlinTest {
  @JvmField @RegisterExtension
  val platform = PlatformRule()

  @JvmField @RegisterExtension
  val clientTestRule =
    OkHttpClientTestRule().apply {
      recordFrames = true
      recordSslDebug = true
    }

  private var client = clientTestRule.newClient()
  private val handshakeCertificates = platform.localhostHandshakeCertificates()
  private lateinit var server: MockWebServer

  @BeforeEach

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Jan 20 10:30:28 UTC 2024

- 8.4K bytes

- Viewed (0)

Search Options