### Question:
BetweennessCentralityStreamProc extends StreamProc<BetweennessCentrality, HugeAtomicDoubleArray, CentralityStreamResult, BetweennessCentralityStreamConfig> { @Procedure(value = "gds.betweenness.stream", mode = READ) @Description(BETWEENNESS_DESCRIPTION) public Stream<CentralityStreamResult> stream( @Name(value = "graphName") Object graphNameOrConfig, @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration ) { var computationResult = compute( graphNameOrConfig, configuration ); return stream(computationResult); }  @Procedure(value = "gds.betweenness.stream", mode = READ) @Description(BETWEENNESS_DESCRIPTION) Stream<CentralityStreamResult> stream(
        @Name(value = "graphName") Object graphNameOrConfig,
        @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration
    ); @Procedure(value = "gds.betweenness.stream.estimate", mode = READ) @Description(BETWEENNESS_DESCRIPTION) Stream<MemoryEstimateResult> estimate(
        @Name(value = "graphName") Object graphNameOrConfig,
        @Name(value = "configuration", defaultValue = "{}") Map<String, Object> configuration
    );  }### Answer:
@Test void testStream() { var query = GdsCypher.call() .withAnyLabel() .withAnyRelationshipType() .algo("gds.betweenness") .streamMode() .yields(); var actual = new HashMap<Long, Double>(); runQueryWithRowConsumer( query, row -> actual.put(row.getNumber("nodeId").longValue(), row.getNumber("score").doubleValue()) ); assertMapEqualsWithTolerance(EXPECTED, actual, 1E-1); }