Function TestMultiStreamer

pkg/blobserver/multistream_test.go:69–86

(t *testing.T)

}

func TestMultiStreamer(t *testing.T) {
	var streamers []blobserver.BlobStreamer
	var want []blob.SizedRef
	n := 0

	for st := 0; st < 3; st++ {
		var blobs []*blob.Blob
		for i := 0; i < 3; i++ {
			n++
			tb := &test.Blob{Contents: strconv.Itoa(n)}
			b := tb.Blob()
			want = append(want, b.SizedRef()) // overall
			blobs = append(blobs, b)          // this sub-streamer
		}
		streamers = append(streamers, staticStreamer(blobs))
	}
	storagetest.TestStreamer(t, blobserver.NewMultiBlobStreamer(streamers...), storagetest.WantSizedRefs(want))
}