INNER CODE UNIT · Go

ok

cshum/imagor · blob_test.go:296

	_, ok = rs.(*seekstream.SeekStream)
	assert.False(t, ok)
}

func TestBlobNewReadSeeker_UsesAsyncForSmallKnownSize(t *testing.T) {
	b := NewBlob(func() (io.ReadCloser, int64, error) {
		return nopReadCloser{Reader: bytes.NewReader([]byte("012345"))}, 6, nil
	})

	rs, size, err := b.NewReadSeeker()
	require.NoError(t, err)
	defer rs.Close()

	assert.Equal(t, int64(6), size)
	_, ok := rs.(*seekstream.AsyncReadSeeker)
	assert.True(t, ok)
}

View source record →