Method ReceiveBlob

pkg/test/fetcher.go:73–83

(ctx context.Context, br blob.Ref, source io.Reader)

}

func (tf *Fetcher) ReceiveBlob(ctx context.Context, br blob.Ref, source io.Reader) (blob.SizedRef, error) {
	sb, err := tf.Storage.ReceiveBlob(ctx, br, source)
	if err != nil {
		return sb, err
	}
	if err := tf.ReceiveErr; err != nil {
		tf.RemoveBlobs(ctx, []blob.Ref{br})
		return sb, err
	}
	return sb, nil
}

func (tf *Fetcher) AddBlob(b *Blob) {
	_, err := tf.ReceiveBlob(context.Background(), b.BlobRef(), b.Reader())