digitalmisfits comments

Repositories
Issues
Comments

Results 2 comments of


                                            digitalmisfits

GroupBy hangs with low cardinality groups; premature closing and fast publisher.

@simonbasle I adopted this method originally from your post on stack-overflow ``` source.groupBy(v -> v.intValue() % 2) .flatMap(group -> group .take(Duration.ofMillis(1000)) .count() .map(c -> "group " + group.key() + "...

GroupBy hangs with low cardinality groups; premature closing and fast publisher.

> FWIW I have experienced a similar hanging behavior in groupBy, and may be related to [this issue](https://github.com/reactor/reactor-core/issues/2352). That issue is more talking about silently dropped onNext signals, but I...