spring-cloud / spring-cloud/spring-cloud-stream

Support of multiple outputs on function composition

Open
#1,991 0 comments 0 reactions 1 assignee View on GitHub

@olegz is already working on this.

Since Jun 30, 2020.

enhancement
Dominant language
Java
Stars
1.1k
Forks
646
Avg merge
2d 3h
Merged PRs (30d)
8

Description

Describe the issue
I'm trying to define the function definition as supplierA|functionB, while they have the following signatures:

@Bean
public Supplier<Flux<Map<String, Object>>> supplierA() { ... }

@Bean
public Function<Flux<Map<String, Object>>, Tuple2<Flux<Map<String, Object>>, Flux<Map<String, Object>>>> functionB() { ... }

Turns out, the composed function would try to output Flux<Tuple2<Flux<Map<String, Object>>, Flux<Map<String, Object>>>> in supplierAfunctionB-out-0, instead of two Flux<Map<String, Object>> in supplierAfunctionB-out-0 and supplierAfunctionB-out-1.

To Reproduce
As above.

Version of the framework
3.0.4.RELEASE

Expected behavior
Somehow allow configuring the multiple outputs of the composed function.

Contributor guide

No contributing guide indexed for this repository

First steps

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. Open a pull request that references the issue number.

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.