We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b5b27d4 commit 0072c30Copy full SHA for 0072c30
src/test/java/io/reactivex/processors/UnicastProcessorTest.java
@@ -430,7 +430,7 @@ public void alreadyCancelled() {
430
public void unicastSubscriptionBadRequest() {
431
UnicastProcessor<Integer> us = UnicastProcessor.create(false);
432
433
- UnicastProcessor<Integer>.UnicastQueueSubscription usc = us.new UnicastQueueSubscription();
+ UnicastProcessor<Integer>.UnicastQueueSubscription usc = (UnicastProcessor<Integer>.UnicastQueueSubscription)us.wip;
434
435
List<Throwable> errors = TestHelper.trackPluginErrors();
436
try {
0 commit comments