Closed - Code Search

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

    testEmptyRangeSubMultiset(
        sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), OPEN));
    testEmptyRangeSubMultiset(
        sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), CLOSED));
    testEmptyRangeSubMultiset(
        sortedMultiset.subMultiset(b.getElement(), CLOSED, a.getElement(), CLOSED));
    testEmptyRangeSubMultiset(

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Tue Feb 20 17:00:05 GMT 2024

- 25.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

    this.withLock {
      cancel = !source.finished && source.closed && (sink.finished || sink.closed)
      open = isOpen
    }
    if (cancel) {
      // RST this stream to prevent additional data from being sent. This is safe because the input
      // stream is closed (we won't use any further bytes) and the output stream is either finished
      // or closed (so RSTing both streams doesn't cause harm).

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sat Apr 20 17:03:43 GMT 2024

- 23.2K bytes

- Viewed (1)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt

      return webSocket!!.processNextFrame()
    }

    override fun close() {
      if (closed) {
        throw AssertionError("Already closed")
      }
      try {
        source.close()
      } catch (ignored: IOException) {
      }
      try {
        sink.close()
      } catch (ignored: IOException) {
      }
      closed = true
    }

    override fun cancel() {
      canceled = true

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Thu Apr 11 01:59:58 GMT 2024

- 18.5K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/GeneralRangeTest.java

    assertEquals(
        GeneralRange.range(ORDERING, 3, CLOSED, 4, OPEN),
        range.intersect(GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED)));
  }

  public void testIntersectOverlappingRange() {
    GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED);
    assertEquals(
        GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED),

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Thu Mar 07 18:34:03 GMT 2024

- 8.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/GeneralRangeTest.java

    assertEquals(
        GeneralRange.range(ORDERING, 3, CLOSED, 4, OPEN),
        range.intersect(GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED)));
  }

  public void testIntersectOverlappingRange() {
    GeneralRange<Integer> range = GeneralRange.range(ORDERING, 2, OPEN, 4, CLOSED);
    assertEquals(
        GeneralRange.range(ORDERING, 3, CLOSED, 4, CLOSED),

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Mar 07 18:34:03 GMT 2024

- 8.4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/ContiguousSetTest.java

    assertEquals(Range.closed(1, 3), ContiguousSet.create(Range.closed(1, 3), integers()).range());
    assertEquals(Range.closed(1, 3), ContiguousSet.closed(1, 3).range());
    assertEquals(
        Range.closed(1, 3), ContiguousSet.create(Range.closedOpen(1, 4), integers()).range());
    assertEquals(Range.closed(1, 3), ContiguousSet.closedOpen(1, 4).range());

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Mon Feb 19 20:34:55 GMT 2024

- 19.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/ContiguousSetTest.java

    assertEquals(Range.closed(1, 3), ContiguousSet.create(Range.closed(1, 3), integers()).range());
    assertEquals(Range.closed(1, 3), ContiguousSet.closed(1, 3).range());
    assertEquals(
        Range.closed(1, 3), ContiguousSet.create(Range.closedOpen(1, 4), integers()).range());
    assertEquals(Range.closed(1, 3), ContiguousSet.closedOpen(1, 4).range());

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Mon Feb 19 20:34:55 GMT 2024

- 19.1K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/progress.go

func (pr *progressReader) Close() error {
	pr.closedMu.Lock()
	defer pr.closedMu.Unlock()
	if pr.closed {
		return nil
	}
	pr.closed = true
	if pr.closer != nil {
		pr.closer.Close()
	}
	return pr.rc.Close()
}

func (pr *progressReader) Stats() (bytesScanned, bytesProcessed int64) {
	if pr == nil {
		return 0, 0
	}
	return pr.scannedReader.BytesRead(), pr.processedReader.BytesRead()
}

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Mon Oct 18 15:44:36 GMT 2021

- 4.2K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/simdj/reader.go

	if !ok {
		dstRec = &Record{}
	}
	dstRec.object = v
	return dstRec, nil
}

// Close - closes underlying reader.
func (r *Reader) Close() error {
	// Close the input.
	// Potentially racy if the stream decoder is still reading.
	if r.readCloser != nil {
		r.readCloser.Close()
	}
	if r.exitReader != nil {
		close(r.exitReader)
		r.readerWg.Wait()
		r.exitReader = nil
		r.input = nil
	}
	return nil
}

Go

- Registered: Sun Apr 21 19:28:08 GMT 2024

- Last Modified: Tue May 30 17:02:22 GMT 2023

- 4.9K bytes

- Viewed (0)

github.com/google/guava

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

    testEmptyRangeSubMultiset(
        sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), OPEN));
    testEmptyRangeSubMultiset(
        sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), CLOSED));
    testEmptyRangeSubMultiset(
        sortedMultiset.subMultiset(b.getElement(), CLOSED, a.getElement(), CLOSED));
    testEmptyRangeSubMultiset(

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Tue Feb 20 17:00:05 GMT 2024

- 25.9K bytes

- Viewed (0)

Search Options