File tree Expand file tree Collapse file tree 2 files changed +0
-2
lines changed
src/main/java/rx/internal/operators Expand file tree Collapse file tree 2 files changed +0
-2
lines changed Original file line number Diff line number Diff line change @@ -147,7 +147,6 @@ public void remove() {
147
147
148
148
private static class NextObserver <T > extends Subscriber <Notification <? extends T >> {
149
149
private final BlockingQueue <Notification <? extends T >> buf = new ArrayBlockingQueue <Notification <? extends T >>(1 );
150
- @ SuppressWarnings ("unused" )
151
150
final AtomicInteger waiting = new AtomicInteger ();
152
151
153
152
@ Override
Original file line number Diff line number Diff line change @@ -185,7 +185,6 @@ static class ConcatInnerSubscriber<T> extends Subscriber<T> {
185
185
186
186
private final Subscriber <T > child ;
187
187
private final ConcatSubscriber <T > parent ;
188
- @ SuppressWarnings ("unused" )
189
188
private final AtomicInteger once = new AtomicInteger ();
190
189
private final ProducerArbiter arbiter ;
191
190
You can’t perform that action at this time.
0 commit comments