spring-cloud / spring-cloud/spring-cloud-stream
Support of multiple outputs on function composition
@olegz is already working on this.
Since Jun 30, 2020.
- 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
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Assessment
This issue has not been assessed yet.