ygerzhedovich commented on code in PR #1469:
URL: https://github.com/apache/ignite-3/pull/1469#discussion_r1085175526
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/SubscriptionUtils.java:
##########
@@ -49,6 +50,31 @@ public static <T> Publisher<T> concat(Publisher<? extends
T>... sources) {
return new ConcatenatedPublisher<>(Arrays.asList(sources).iterator());
}
+ /**
+ * Create thread-safe publisher wrapper of combine multiple publishers,
sources for whom are suppliers what can be used for lazy
+ * opening these publishers . Generally, start consuming a source once the
previous source has terminated, building a chain.
+ *
+ * @param sources Array of publisher suppliers which should be combine.
+ * @return Publisher which will be combine all of passed as parameter to
single one.
+ */
+ @SafeVarargs
+ public static <T> Publisher<T> concat(Supplier<Publisher<T>>... sources) {
Review Comment:
thanks, reworked
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
