subnet - Code Search

android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

    TestRunnable runnable = new TestRunnable();
    ListenableFuture<?> runnableFuture = e.submit(runnable);
    assertThat(runnableFuture).isInstanceOf(TrustedListenableFutureTask.class);
    assertTrue(runnableFuture.isDone());
    assertTrue(runnable.run);

    ListenableFuture<String> callableFuture = e.submit(new TestCallable());
    assertThat(callableFuture).isInstanceOf(TrustedListenableFutureTask.class);

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 19 18:03:30 GMT 2024

- 3.2K bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/nats_tls_contrib_test.go

	defer s.Shutdown()

	clientConfig := &NATSArgs{
		Enable: true,
		Address: xnet.Host{
			Name:      "localhost",
			Port:      (xnet.Port(opts.Port)),
			IsPortSet: true,
		},
		Subject:       "test",
		Secure:        true,
		CertAuthority: path.Join("testdata", "contrib", "certs", "root_ca_cert.pem"),
	}

	con, err := clientConfig.connectNats()
	if err != nil {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Apr 22 22:12:26 GMT 2025

- 2.7K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/request_files/tutorial002_an_py39.py

    content = """
<body>
<form action="/files/" enctype="multipart/form-data" method="post">
<input name="files" type="file" multiple>
<input type="submit">
</form>
<form action="/uploadfiles/" enctype="multipart/form-data" method="post">
<input name="files" type="file" multiple>
<input type="submit">
</form>
</body>
    """

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Sat Mar 18 12:29:59 GMT 2023

- 826 bytes

- Click Count (0)

github.com/minio/minio

internal/amztime/iso8601_time.go

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package amztime

import (
	"strings"
	"time"
)

// RFC3339 a subset of the ISO8601 timestamp format. e.g 2014-04-29T18:30:38Z
const (
	iso8601TimeFormat     = "2006-01-02T15:04:05.000Z"    // Reply date format with millisecond precision.

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Mon Jan 16 23:38:33 GMT 2023

- 1.9K bytes

- Click Count (0)

github.com/minio/minio

cmd/object-api-options_test.go

package cmd

import (
	"net/http"
	"net/http/httptest"
	"reflect"
	"testing"

	xhttp "github.com/minio/minio/internal/http"
)

// TestGetAndValidateAttributesOpts is currently minimal and covers a subset of getAndValidateAttributesOpts(),
// it is intended to be expanded when the function is worked on in the future.
func TestGetAndValidateAttributesOpts(t *testing.T) {
	globalBucketVersioningSys = &BucketVersioningSys{}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Wed Apr 09 14:28:39 GMT 2025

- 2.4K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/request_files/tutorial003_py39.py

    content = """
<body>
<form action="/files/" enctype="multipart/form-data" method="post">
<input name="files" type="file" multiple>
<input type="submit">
</form>
<form action="/uploadfiles/" enctype="multipart/form-data" method="post">
<input name="files" type="file" multiple>
<input type="submit">
</form>
</body>
    """

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Fri May 13 23:38:22 GMT 2022

- 888 bytes

- Click Count (0)

github.com/square/okhttp

okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Certificate.kt

  val signatureValue: BitString,
) {
  val commonName: Any?
    get() {
      return tbsCertificate.subject
        .flatten()
        .firstOrNull { it.type == ObjectIdentifiers.COMMON_NAME }
        ?.value
    }

  val organizationalUnitName: Any?
    get() {
      return tbsCertificate.subject
        .flatten()
        .firstOrNull { it.type == ObjectIdentifiers.ORGANIZATIONAL_UNIT_NAME }
        ?.value

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 6.4K bytes

- Click Count (0)

github.com/minio/minio

internal/pubsub/pubsub.go

		atomic.AddInt32(&ps.numSubscribers, -1)
		return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers)
	}
	ps.Lock()
	defer ps.Unlock()
	subChT := make(chan T, 10000)
	sub := &Sub[T]{ch: subChT, types: Mask(mask.Mask()), filter: filter}
	ps.subs = append(ps.subs, sub)

	// We hold a lock, so we are safe to update
	combined := Mask(atomic.LoadUint64(&ps.types))

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Feb 06 16:57:30 GMT 2024

- 5.2K bytes

- Click Count (0)

github.com/google/guava

guava-testlib/src/com/google/common/collect/testing/testers/NavigableSetNavigationTester.java

    assertEquals(values, descending);
  }

  public void testEmptySubSet() {
    NavigableSet<E> empty = navigableSet.subSet(e0(), false, e0(), false);
    assertEquals(new TreeSet<E>(), empty);
  }

  /*
   * TODO(cpovirk): more testing of subSet/headSet/tailSet/descendingSet? and/or generate derived
   * suites?
   */

  /**

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Nov 14 23:40:07 GMT 2024

- 8.5K bytes

- Click Count (0)

github.com/google/guava

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

    @Override
    public SortedSet<E> create(Object... elements) {
      List<?> normalValues = (List<?>) asList(elements);
      List<E> extremeValues = new ArrayList<>();

      // nulls are usually out of bounds for a subset, so ban them altogether
      for (Object o : elements) {
        if (o == null) {
          throw new NullPointerException();
        }
      }

      // prepare extreme values to be filtered out of view

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Jan 30 16:59:10 GMT 2025

- 18.2K bytes

- Click Count (0)

Search Options