模拟 CloudBlockBlob 并让它返回一个流

Question

我正在尝试最小化一个 Azure CloudBlockBlob 并让它返回一个 Stream 以便我可以测试我的 BlobStorage 存储库是否正确处理输出。

但不知何故，返回的流总是空的。

单元测试代码：

//....

var stream = new MemoryStream();
var writer = new StreamWriter(stream);
writer.Write("sample data");
writer.Flush();
stream.Position = 0;

var blobMock = new Mock<CloudBlockBlob>(new Uri("http://tempuri.org/blob"));
blobMock
    .Setup(m => m.ExistsAsync())
    .ReturnsAsync(true);
blobMock
    .Setup(m => m.DownloadToStreamAsync(It.IsAny<MemoryStream>()))
    .Returns(Task.FromResult(stream));

//....

存储库代码：

//....

var blob = GetContainer(container).GetBlockBlobReference(name);
if (await blob.ExistsAsync())
{
    var ms = new MemoryStream();
    await blob.DownloadToStreamAsync(ms);
    ms.Seek(0, SeekOrigin.Begin);
    return ms;
}

//....

所以我返回的 MemoryStream ms 始终是一个空流，而不是我在 Moq Returns() 方法中使用的 stream 对象。

如何让该 blob 返回我的示例流？

Answer 1

这是两个不同的流。在Callback 中获取在模拟参数中传递的流并复制测试流。

例如

//....
var stream = new MemoryStream();
var writer = new StreamWriter(stream);
writer.Write("sample data");
writer.Flush();
stream.Position = 0;

var blobMock = new Mock<CloudBlockBlob>(new Uri("http://tempuri.org/blob"));
blobMock
    .Setup(m => m.ExistsAsync())
    .ReturnsAsync(true);
blobMock
    .Setup(m => m.DownloadToStreamAsync(It.IsAny<Stream>()))
    .Callback((Stream target) => stream.CopyTo(target)) //<---Something like this
    .Returns(Task.CompletedTask);
//....

模拟实际上并不返回流。假设作用于流，这就是为什么需要回调来复制预期行为的原因。

注意

复制从当前流中的当前位置开始，复制操作完成后不会重置目标流的位置。

所以在这种情况下，如果打算从目标读取，您可能需要重置它

//...

.Callback((Stream target) => {
    stream.CopyTo(target);
    target.Position = 0;
})

//...