stream-applications

Files

Artem Bilan 6a380c4d19 Change doOnSubscribe to doOnRequest

The `aggregatorFunction` has a flaw subscribing and emitting
data from a source `Flux` too early: from a `doOnSubscribe()`
callback which is really called *before* the real subscription is
registered in the target `Publisher`

Change the logic to the `doOnRequest()` which happens already
after subscription is registered in the `Publisher`

**Cherry-pick to `2020.0.x`**

2022-01-20 18:35:30 -05:00

src

Change doOnSubscribe to doOnRequest

2022-01-20 18:35:30 -05:00

pom.xml

Restructuing with maven revision feature

2020-10-13 15:17:52 -04:00

README.adoc

Add Aggregator function & processor

2020-08-20 15:54:51 -04:00

README.adoc

# Aggregator Function

This module provides an aggregation function that can be reused and composed in other applications.

## Beans for injection

You can import the `AggregatorFunctionConfiguration` in a Spring Boot application and then inject the following bean.

`aggregatorFunction`

You can use `aggregatorFunction` as a qualifier when injecting.

Once injected, you can use the `apply` method of the `Function` to invoke it and get the result.

## Configuration Options

For more information on the various options available, please see link:src/main/java/org/springframework/cloud/fn/aggregator/AggregatorFunctionProperties.java[AggregatorFunctionProperties.java]

## Tests

See this link:src/test/java/org/springframework/cloud/fn/aggregator/AggregatorFunctionApplicationTests.java[test suite] for examples of how this function is used.

## Other usage

See this link:../../../applications/processor/aggregator-processor/README.adoc[README] where this function is used to create a Spring Cloud Stream application.