diff --git a/src/main/java/run/halo/app/theme/finders/impl/ContributorFinderImpl.java b/src/main/java/run/halo/app/theme/finders/impl/ContributorFinderImpl.java index ecbcbf28b..60e6b7e55 100644 --- a/src/main/java/run/halo/app/theme/finders/impl/ContributorFinderImpl.java +++ b/src/main/java/run/halo/app/theme/finders/impl/ContributorFinderImpl.java @@ -36,6 +36,6 @@ public class ContributorFinderImpl implements ContributorFinder { return Flux.empty(); } return Flux.fromIterable(names) - .flatMap(this::getContributor); + .concatMap(this::getContributor); } } diff --git a/src/main/java/run/halo/app/theme/finders/impl/PostFinderImpl.java b/src/main/java/run/halo/app/theme/finders/impl/PostFinderImpl.java index a59a6fe54..f49f91a43 100644 --- a/src/main/java/run/halo/app/theme/finders/impl/PostFinderImpl.java +++ b/src/main/java/run/halo/app/theme/finders/impl/PostFinderImpl.java @@ -127,7 +127,7 @@ public class PostFinderImpl implements PostFinder { @Override public Flux listAll() { return client.list(Post.class, FIXED_PREDICATE, defaultComparator()) - .flatMap(this::getListedPostVo); + .concatMap(this::getListedPostVo); } static Pair postPreviousNextPair(List postNames, @@ -292,7 +292,7 @@ public class PostFinderImpl implements PostFinder { return client.list(Post.class, predicate, comparator, pageNullSafe(page), sizeNullSafe(size)) .flatMap(list -> Flux.fromStream(list.get()) - .flatMap(post -> getListedPostVo(post) + .concatMap(post -> getListedPostVo(post) .map(postVo -> { populateStats(postVo); return postVo; diff --git a/src/main/java/run/halo/app/theme/finders/impl/SinglePageFinderImpl.java b/src/main/java/run/halo/app/theme/finders/impl/SinglePageFinderImpl.java index d2b737d98..cac48a350 100644 --- a/src/main/java/run/halo/app/theme/finders/impl/SinglePageFinderImpl.java +++ b/src/main/java/run/halo/app/theme/finders/impl/SinglePageFinderImpl.java @@ -96,7 +96,7 @@ public class SinglePageFinderImpl implements SinglePageFinder { populateStats(pageVo); return pageVo; }) - .flatMap(this::populateContributors) + .concatMap(this::populateContributors) .collectList() .map(pageVos -> new ListResult<>(list.getPage(), list.getSize(), list.getTotal(), pageVos) diff --git a/src/main/java/run/halo/app/theme/finders/impl/TagFinderImpl.java b/src/main/java/run/halo/app/theme/finders/impl/TagFinderImpl.java index 84109a914..d13173ceb 100644 --- a/src/main/java/run/halo/app/theme/finders/impl/TagFinderImpl.java +++ b/src/main/java/run/halo/app/theme/finders/impl/TagFinderImpl.java @@ -40,7 +40,7 @@ public class TagFinderImpl implements TagFinder { @Override public Flux getByNames(List names) { return Flux.fromIterable(names) - .flatMap(this::getByName); + .concatMap(this::getByName); } @Override