单元测试Elastic Search Nest客户端-BulkAll

问题描述

我正在为ElasticSearch nest .net客户端编写单元测试。

我在存储库类中有以下调用

var observable = _client.BulkAll(documents,selector => selector
        .BackOffTime("30s")
        .BackOffRetries(2)
        .RefreshOnCompleted()
        .Size(1000)
    ).Wait(
        TimeSpan.FromMinutes(15),next => {
            _logger.Loginformation($"Adding {next.Items.Count} number of items");
    });

在单元测试中，我有：

client = Substitute.For<IElasticclient>();
await _repository.AddDocuments(documents);
_client.Received().BulkAll(Arg.Any<IBulkAllRequest<Purchase>);

但是运行单元测试时出现以下异常

Value cannot be null. (Parameter 'observable')
   at nest.Extensions.ThrowIfNull[T](T value,String name,String message)

我不确定如何正确构建单元测试。

非常感谢任何帮助

解决方法

我认为您的问题是您正在使用带有此签名的BulkAll超载

public BulkAllObservable<T> BulkAll<T>(IEnumerable<T> documents,Func<BulkAllDescriptor<T>,IBulkAllRequest<T>> selector,CancellationToken cancellationToken = default)

但是您要准备一个替代品

public BulkAllObservable<T> BulkAll<T>(IBulkAllRequest<T> request,CancellationToken cancellationToken = default)

要解决此问题，我将通过以下方式配置替代项

elasticClient
    .Received()
    .BulkAll(
        Arg.Any<IEnumerable<Document>>(),Arg.Any<Func<BulkAllDescriptor<Document>,IBulkAllRequest<Document>>>());

Document类型需要替换为您实际使用的类型。