ストリームは常に空です - 私が時間を与えない限り

Question

私はJavaストリームを理解するのに少し問題があります。基本的に要素をデータベースに格納し、取得し（結果はストリームで返されます）、次に両方の要素を比較するJUnitテストを作成しました。テストに失敗したので、デバッグを開始しました。突然テストが合格した。私のブレークポイントは、ストリームを作るのに必要な時間を与えましたか？

データベースとしてElasticsearchと

@Test 
public void matchAllTest() { 
    client.insert(object); //database schema is empty 

    Stream<Object> stream = client.query("{ query matching all objects }"); 

    Object firstResult = stream.findFirst().get(); 
    assertObjectEquals(object, firstResult); 
} 

query作品と次のようになります試験に

public Stream<Object> query(String query) { 
    SearchRequestBuilder request = client.prepareSearch("index"); 
    request.setQuery(query); 

    Stream.Builder<Object> stream = Stream.builder(); 

    SearchResponse response = request.get(); 
    SearchHits hits = response.getHits(); 
    hits.forEach(object -> stream.accept(object); 

    return stream.build(); 
} 

clientはquery方法でクラスを指します。 2番目のコードスニペットのclientは、Elasticsearchノードクライアントを指します。ES Java docsを参照してください。

NoSuchElementException（「値はありません」）でテストが失敗します。時間を与えない限り、テストは失敗します。

ここでは正確に何が起こっていますが、どうすれば例外を回避できますか？

Answer 1

問題は、elasticsearchでの更新後にのみドキュメントを検索できることです。

テストの場合は、強制的にrefreshとすることができます。