[rocketmq-streams] branch develop updated: modify the return type of flatmap

[ka...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

karp pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/develop by this push:
     new a256c965 modify the return type of flatmap
     new ecf01cf6 Merge pull request #271 from ni-ze/develop
a256c965 is described below

commit a256c965e4860b18fd1361d69c44ea4e55c97b50
Author: 维章 <un...@gmail.com>
AuthorDate: Wed Feb 15 09:42:07 2023 +0800

    modify the return type of flatmap
---
 .../src/main/java/org/apache/rocketmq/streams/core/rstream/RStream.java | 2 +-
 .../main/java/org/apache/rocketmq/streams/core/rstream/RStreamImpl.java | 2 +-
 2 files changed, 2 insertions(+), 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
index 7ff181be..85a6fb73 100644
--- 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
index f9da6ee7..d84626f1 100644
--- 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 class RStreamImpl<T> implements RStream<T> {
     }
 
     @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);