### Question:
PearsonProc extends AlphaSimilarityProc<PearsonAlgorithm, PearsonConfig> { @Procedure(name = "gds.alpha.similarity.pearson.stream", mode = READ) @Description(DESCRIPTION) public Stream<SimilarityResult> pearsonStream( @Name(value = "graphName") Object graphNameOrConfig, @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration ) { return stream(graphNameOrConfig, configuration); }  @Procedure(name = "gds.alpha.similarity.pearson.stream", mode = READ) @Description(DESCRIPTION) Stream<SimilarityResult> pearsonStream(
        @Name(value = "graphName") Object graphNameOrConfig,
        @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration
    ); @Procedure(name = "gds.alpha.similarity.pearson.write", mode = WRITE) @Description(DESCRIPTION) Stream<SimilaritySummaryResult> pearsonWrite(
        @Name(value = "graphName") Object graphNameOrConfig,
        @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration
    ); @Procedure(name = "gds.alpha.similarity.pearson.stats", mode = WRITE) @Description(DESCRIPTION) Stream<SimilarityStatsResult> pearsonStats(
        @Name(value = "graphName") Object graphNameOrConfig,
        @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration
    );  }### Answer:
@Test void pearsonStreamTest() { Map<String, Object> params = map("config", map("concurrency", 1, "topK", 0), "missingValue", 0); runQueryWithResultConsumer(STATEMENT_STREAM, params, 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()); }); }