}

	line, isPrefix, err := l.ReadLine()
	if err != io.EOF {
		t.Errorf("expected EOF from ReadLine, got '%s' %t %s", line, isPrefix, err)
	}
}

func TestReadLineNonNilLineOrError(t *testing.T) {
	r := NewReader(strings.NewReader("line 1\n"))
	for i := 0; i < 2; i++ {
		l, _, err := r.ReadLine()
		if l != nil && err != nil {

        if (opLambda != null) {
            opLambda.callback(builder);
        }
    }

    public void setReading_SpanTerm(String reading) {
        setReading_SpanTerm("reading", null);
    }

    public void setReading_SpanTerm(String reading, ConditionOptionCall<SpanTermQueryBuilder> opLambda) {
        SpanTermQueryBuilder builder = regSpanTermQ("reading", reading);

    }

    public void setReading_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) {
        setReading_Terms("reading", opLambda, null);
    }

    public void setReading_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsElevateWordCA> aggsLambda) {
        setReading_Terms("reading", opLambda, aggsLambda);
    }

	}
	r, err := NewReader(bytes.NewReader(data), int64(len(data)))
	if err != ErrInsecurePath {
		t.Fatalf("Error reading the archive: %v", err)
	}
	_, err = r.Open("test.txt")
	if err != nil {
		t.Errorf("Error reading file: %v", err)
	}
	if len(r.File) != 1 {
		t.Fatalf("No entries in the file list")
	}
	if r.File[0].Name != "../test.txt" {

// for io.EOF.
//
// If an EOF happens after reading some but not all the bytes,
// ReadFile returns ErrUnexpectedEOF.
//
// If the BitrotVerifier is not nil or not verified ReadFile
// tries to verify whether the disk has bitrot.
//
// Additionally ReadFile also starts reading from an offset. ReadFile
// semantics are same as io.ReadFull.

labels.jobStatus=Status
labels.labelTypeIds=Labels
labels.lang=Language
labels.outputs=Outputs
labels.pos=Part-of-speech
labels.purgeJobLogDay=Delete old job logs
labels.purgeUserInfoDay=Delete old user logs
labels.reading=Reading
labels.roleTypeIds=Role IDs
labels.scriptData=Script
labels.scriptResult=Result
labels.scriptType=Execution Method
labels.segmentation=Segmentation
labels.startTime=Start Time
labels.target=Target

    HTTP 408 Request Timeout. If retries are enabled, OkHttp will retry exactly
    once in response to a 408.
 *  Fix: Don't crash when reading the empty `HEAD` response body if it specifies
    a `Content-Length`.
 *  Fix: Don't crash if the thread is interrupted while reading the public
    suffix database.
 *  Fix: Use relative resource path when loading the public suffix database.

labels.jobStatus=Status
labels.labelTypeIds=Labels
labels.lang=Language
labels.outputs=Outputs
labels.pos=Part-of-speech
labels.purgeJobLogDay=Delete old job logs
labels.purgeUserInfoDay=Delete old user logs
labels.reading=Reading
labels.roleTypeIds=Role IDs
labels.scriptData=Script
labels.scriptResult=Result
labels.scriptType=Execution Method
labels.segmentation=Segmentation
labels.startTime=Start Time
labels.target=Target

	if !opts.NoAuditLog {
		auditObjectErasureSet(ctx, "GetObjectInfo", object, &er)
	}

	if !opts.NoLock {
		// Lock the object before reading.
		lk := er.NewNSLock(bucket, object)
		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
		if err != nil {
			return ObjectInfo{}, err
		}
		ctx = lkctx.Context()
		defer lk.RUnlock(lkctx)
	}

    editor.commit()
  }

  @Test
  fun `Windows cannot write while reading`() {
    Assumptions.assumeTrue(windows)

    set("k1", "a", "a")
    val snapshot = cache["k1"]!!
    assertThat(cache.edit("k1")).isNull()
    snapshot.close()
  }

  @Test
  fun `can read while reading`() {
    set("k1", "a", "a")
    cache["k1"]!!.use { snapshot1 ->