Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

ensures no compete on onSubscribe and onComplete calls #1696

Merged
merged 2 commits into from Jun 30, 2021
Merged

Conversation

OlegDokuka
Copy link
Contributor

closes #1684

Signed-off-by: Oleh Dokuka odokuka@vmware.com
Signed-off-by: Oleh Dokuka oleh.dokuka@icloud.com

@OlegDokuka OlegDokuka requested review from violetagg and a team June 28, 2021 11:18
Copy link
Member

@simonbasle simonbasle left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

small typo, but otherwise looks good to me. great to have race tests

@violetagg violetagg added this to the 1.0.9 milestone Jun 28, 2021
also, this fix ensures that if we have addListener racing with cancel we always have all elements cleaned from the list

Signed-off-by: Oleh Dokuka <odokuka@vmware.com>
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
Copy link
Member

@violetagg violetagg left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please resolve the build warning:

> Task :reactor-netty-core:compileTestJava
/.../reactor-netty/reactor-netty-core/src/test/java/reactor/netty/FutureMonoTest.java:176: warning: [unchecked] unchecked cast
                        return (GenericFutureListener<? extends Future<?>>[]) listeners1.get(objListener);
                                                                                            ^
  required: GenericFutureListener<? extends Future<?>>[]
  found:    Object
1 warning

Signed-off-by: Oleh Dokuka <odokuka@vmware.com>
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
@violetagg violetagg merged commit 7d9a05f into main Jun 30, 2021
@violetagg violetagg deleted the bugfix/1684 branch June 30, 2021 17:05
@violetagg
Copy link
Member

@OlegDokuka Thanks for the PR!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

MonoToCompletableFuture#get never return because the invocation of onComplete method before onSubscribe
4 participants