street - Code Search

guava/src/com/google/common/collect/ImmutableRangeMap.java

import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.NoSuchElementException;
import java.util.function.BiFunction;
import java.util.function.Function;
import java.util.stream.Collector;
import org.jspecify.annotations.Nullable;

/**
 * A {@link RangeMap} whose contents will never change, with many other important properties
 * detailed at {@link ImmutableCollection}.
 *

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Jul 17 15:26:41 UTC 2025

- 14.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/bitrot.go

func NewBitrotVerifier(algorithm BitrotAlgorithm, checksum []byte) *BitrotVerifier {
	return &BitrotVerifier{algorithm, checksum}
}

// BitrotVerifier can be used to verify protected data.
type BitrotVerifier struct {
	algorithm BitrotAlgorithm
	sum       []byte
}

// BitrotAlgorithmFromString returns a bitrot algorithm from the given string representation.

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Wed Feb 26 19:26:13 UTC 2025

- 7.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/hash/PrimitiveSink.java

import com.google.common.annotations.Beta;
import com.google.errorprone.annotations.CanIgnoreReturnValue;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;

/**
 * An object which can receive a stream of primitive values.
 *
 * @author Kevin Bourrillion
 * @since 12.0 (in 11.0 as {@code Sink})
 */
@Beta
public interface PrimitiveSink {
  /**
   * Puts a byte into this sink.
   *
   * @param b a byte

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Sat Dec 21 03:10:51 UTC 2024

- 3.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/https/HandlerTest.java

import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;

/**
 * Test suite for jcifs.smb1.https.Handler class.
 * Tests HTTPS URL stream handler functionality with NTLM authentication support.
 */
@DisplayName("SMB1 HTTPS Handler Tests")
class HandlerTest {

    private Handler handler;

    @BeforeEach
    void setUp() {

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 6.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

      .assertLogEqual("Content-Type: text/event-stream")
      .assertLogMatch(Regex("""Transfer-encoding: chunked"""))
      .assertLogEqual("<-- END HTTP (streaming)")
      .assertNoMoreLogs()
    applicationLogs
      .assertLogEqual("--> GET $url")
      .assertLogEqual("--> END GET")
      .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)"""))
      .assertLogEqual("Content-Type: text/event-stream")

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Thu Aug 21 14:27:04 UTC 2025

- 37.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/OsddHelperTest.java

import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;
import org.lastaflute.web.response.StreamResponse;
import org.lastaflute.web.servlet.request.stream.WrittenStreamOut;

public class OsddHelperTest extends UnitFessTestCase {

    public void test_init_nofile() {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            @Override

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jul 19 23:49:30 UTC 2025

- 23.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/ResourceManagerTest.java

        var activeResources = resourceManager.getActiveResources();
        assertNotNull(activeResources);
        assertFalse(activeResources.isEmpty());

        boolean found = activeResources.stream().anyMatch(desc -> desc.contains("TestResource"));
        assertTrue(found);
    }

    @Test
    @DisplayName("Test multiple close calls on managed resource")

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 8.9K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/resources/plugin/repo2/index.html

    <link rel="SHORTCUT ICON" href="https://oss.sonatype.org/favicon.ico"/>
    <![endif]-->

    <link rel="stylesheet" href="https://oss.sonatype.org/static/css/Sonatype-content.css?2.14.13-01" type="text/css" media="screen" title="no title" charset="utf-8">
  </head>
  <body>
    <h1>Index of /repositories/snapshots/org/codelibs/fess</h1>
    <table cellspacing="10">
      <tr>
        <th align="left">Name</th>

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Tue Aug 13 07:34:14 UTC 2019

- 10.5K bytes

- Viewed (0)

github.com/apache/maven

api/maven-api-core/src/test/java/org/apache/maven/api/services/SourcesTest.java

        assertNull(source.resolve(locator, "subproject"));
        verify(locator, never()).locateExistingPom(any(Path.class));
    }

    @Test
    void testStreamReading() throws IOException {
        // Test stream reading functionality
        Path testFile = tempDir.resolve("test.txt");
        String content = "test content";
        Files.writeString(testFile, content);

        Source source = Sources.fromPath(testFile);

Registered: Sun Sep 07 03:35:12 UTC 2025

- Last Modified: Fri Mar 21 04:56:21 UTC 2025

- 5.2K bytes

- Viewed (0)

github.com/golang/go

src/cmd/asm/internal/lex/lex.go

// the text of the most recently returned token is, and where it was found.
// The underlying scanner elides all spaces except newline, so the input looks like a stream of
// Tokens; original spacing is lost but we don't need it.
type TokenReader interface {
	// Next returns the next token.
	Next() ScanToken
	// The following methods all refer to the most recent token returned by Next.

Registered: Tue Sep 09 11:13:09 UTC 2025

- Last Modified: Tue Aug 29 18:31:05 UTC 2023

- 4.1K bytes

- Viewed (0)

Search Options