最小起订量的ElasticSearch 2.0嵌套单元测试

Func<T1, T2>

It.IsAny<T>()

It.IsAny<Func<SearchDescriptor<Person>, ISearchRequest>>()

一个完整的工作示例

void Main(){    var people = new List<Person>    {        new Person { Id = 1 },        new Person { Id = 2 },    };    var mockSearchResponse = new Mock<ISearchResponse<Person>>();    mockSearchResponse.Setup(x => x.documents).Returns(people);    var mockElasticClient = new Mock<IElasticClient>();    mockElasticClient.Setup(x => x        .Search(It.IsAny<Func<SearchDescriptor<Person>, ISearchRequest>>()))        .Returns(mockSearchResponse.Object);    var result = mockElasticClient.Object.Search<Person>(s => s);    Assert.AreEqual(2, result.documents.Count()).Dump();}public class Person{    public int Id { get; set;}}

如果您不需要 存根 客户端，则只需使用真实客户端并将设置

IConnection

InMemoryConnection

var pool = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));// pass an instance of InMemoryConnection so that requests are not // **actually** sentvar connectionSettings = new ConnectionSettings(pool, new InMemoryConnection())        .PrettyJson()        .DisableDirectStreaming()        .onRequestCompleted(response => {     // log out the request     if (response.RequestBodyInBytes != null)     {         Console.WriteLine(  $"{response.HttpMethod} {response.Uri} n" +  $"{Encoding.UTF8.GetString(response.RequestBodyInBytes)}");     }     else     {         Console.WriteLine($"{response.HttpMethod} {response.Uri}");     }     // log out the response     if (response.ResponseBodyInBytes != null)     {         Console.WriteLine($"Status: {response.HttpStatusCode}n" +       $"{Encoding.UTF8.GetString(response.ResponseBodyInBytes)}n" +       $"{new string('-', 30)}n");     }     else     {         Console.WriteLine($"Status: {response.HttpStatusCode}n" +       $"{new string('-', 30)}n");     } });var client = new ElasticClient(connectionSettings);

这样，您还可以根据需要捕获请求。您可以更进一步，并创建自己的

IConnection