Merge pull request #271 from ni-ze/develop

[ISSUE #268]modify the return type of flatmap
apache · Feb 16, 2023 · ecf01cf · ecf01cf
2 parents 9bff38e + a256c96
commit ecf01cf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java b/core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java
@@ -27,7 +27,7 @@ public interface RStream<T> {
 
     <O> RStream<O> map(ValueMapperAction<T, O> mapperAction);
 
-    <VR> RStream<T> flatMap(final ValueMapperAction<T, ? extends Iterable<? extends VR>> mapper);
+    <VR> RStream<VR> flatMap(final ValueMapperAction<T, ? extends Iterable<? extends VR>> mapper);
 
     RStream<T> filter(FilterAction<T> predictor);
 

diff --git a/core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java b/core/src/main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java
@@ -75,7 +75,7 @@ public <O> RStream<O> map(ValueMapperAction<T, O> mapperAction) {
     }
 
     @Override
-    public <VR> RStream<T> flatMap(ValueMapperAction<T, ? extends Iterable<? extends VR>> mapper) {
+    public <VR> RStream<VR> flatMap(ValueMapperAction<T, ? extends Iterable<? extends VR>> mapper) {
         String name = OperatorNameMaker.makeName(FLAT_MAP_PREFIX, pipeline.getJobId());
 
         MultiValueChangeSupplier<T, VR> changeSupplier = new MultiValueChangeSupplier<>(mapper);