    @Test
    void cosineStreamTest() {

        runQueryWithResultConsumer(STATEMENT_STREAM, map("config", map("concurrency", 1, "topK", 0), "missingValue", 0),
            results -> {
                assertTrue(results.hasNext());
                assert01(results.next());
                assert02(results.next());
                assert03(results.next());
                assert12(results.next());
                assert13(results.next());
                assert23(results.next());
                assertFalse(results.hasNext());
            }
        );
    }