INNER CODE UNIT · Go

TestBlobNewReadSeeker_UsesAsyncForSmallKnownSize

cshum/imagor · blob_test.go:300

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)
}

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

View source record →