We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0def1af commit c62bd5bCopy full SHA for c62bd5b
implementation/src/test/java/io/smallrye/mutiny/operators/MultiGroupTest.java
@@ -1049,7 +1049,7 @@ void testUpstreamRequestsNotBlownOutOfProportion() {
1049
AtomicLong itemCounter = new AtomicLong(0);
1050
AtomicReference<MultiEmitter<? super Integer>> e = new AtomicReference<>();
1051
1052
- Multi.createFrom().<Integer>emitter(e::set)
+ Multi.createFrom().<Integer> emitter(e::set)
1053
.onRequest().invoke(requestCounter::addAndGet)
1054
.group().by(i -> i / 10)
1055
.onItem().transformToMulti(g -> g.map(i -> g.key() + " : " + i)
0 commit comments