-
Notifications
You must be signed in to change notification settings - Fork 1.4k
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
[WFLY-20383] Get rid of compiler warnings #1020
Conversation
@kabir FYI the test with deps (i.e. with wildfly main) gets into a deadend, please see https://github.com/wildfly/quickstart/actions/runs/13520048394/job/37788930160?pr=1020 |
I have triggered another run to double check |
Also fix BroadcastPublisher.onError()
@emmartins Should be good now (and thanks @jamezp for the assistance!) |
@@ -45,7 +45,7 @@ public UserMessagingBean() { | |||
|
|||
@Inject | |||
public UserMessagingBean(@Channel("user") Publisher<String> receiver) { | |||
this.broadcastPublisher = new BroadcastPublisher(receiver); | |||
this.broadcastPublisher = new BroadcastPublisher<String>(receiver); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not critical, but this could just be new BroadcastPubliser<>(receiver);
.
@Override | ||
public void onSubscribe(Subscription subscription) { | ||
baseSubscription = subscription; | ||
subscription.request(1); | ||
} | ||
|
||
@Override | ||
public void onNext(Object o) { | ||
public void onNext(T o) { | ||
System.out.println("Received " + o + " - forwarding it to all the subscribers"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not part of this change, but a System.out.println()
should not be used.
Also fix BroadcastPublisher.onError()
https://issues.redhat.com/browse/WFLY-20383