@@ -2341,20 +2341,21 @@ public void fusedNoConcurrentCleanDueToCancel() {
2341
2341
try {
2342
2342
final PublishProcessor <Integer > pp = PublishProcessor .create ();
2343
2343
2344
- final AtomicReference <QueueSubscription <GroupedFlowable <Object , Integer >>> qs = new AtomicReference <QueueSubscription <GroupedFlowable <Object , Integer >>>();
2344
+ final AtomicReference <QueueSubscription <GroupedFlowable <Integer , Integer >>> qs =
2345
+ new AtomicReference <QueueSubscription <GroupedFlowable <Integer , Integer >>>();
2345
2346
2346
2347
final TestSubscriber <Integer > ts2 = new TestSubscriber <Integer >();
2347
2348
2348
- pp .groupBy (Functions .identity (), Functions .<Integer >identity (), false , 4 )
2349
- .subscribe (new FlowableSubscriber <GroupedFlowable <Object , Integer >>() {
2349
+ pp .groupBy (Functions .< Integer > identity (), Functions .<Integer >identity (), false , 4 )
2350
+ .subscribe (new FlowableSubscriber <GroupedFlowable <Integer , Integer >>() {
2350
2351
2351
2352
boolean once ;
2352
2353
2353
2354
@ Override
2354
- public void onNext (GroupedFlowable <Object , Integer > g ) {
2355
+ public void onNext (GroupedFlowable <Integer , Integer > g ) {
2355
2356
if (!once ) {
2356
2357
try {
2357
- GroupedFlowable <Object , Integer > t = qs .get ().poll ();
2358
+ GroupedFlowable <Integer , Integer > t = qs .get ().poll ();
2358
2359
if (t != null ) {
2359
2360
once = true ;
2360
2361
t .subscribe (ts2 );
@@ -2376,7 +2377,7 @@ public void onComplete() {
2376
2377
@ Override
2377
2378
public void onSubscribe (Subscription s ) {
2378
2379
@ SuppressWarnings ("unchecked" )
2379
- QueueSubscription <GroupedFlowable <Object , Integer >> q = (QueueSubscription <GroupedFlowable <Object , Integer >>)s ;
2380
+ QueueSubscription <GroupedFlowable <Integer , Integer >> q = (QueueSubscription <GroupedFlowable <Integer , Integer >>)s ;
2380
2381
qs .set (q );
2381
2382
q .requestFusion (QueueFuseable .ANY );
2382
2383
q .request (1 );
0 commit comments