Skip to content

Commit 7b11b1c

Browse files
davidmotenzsxwing
authored andcommitted
remove unused field baseCapacity (#3874)
1 parent 3f6c4fd commit 7b11b1c

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

src/main/java/rx/internal/operators/OperatorOnBackpressureBuffer.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,6 @@ public Subscriber<? super T> call(final Subscriber<? super T> child) {
110110
private static final class BufferSubscriber<T> extends Subscriber<T> implements BackpressureDrainManager.BackpressureQueueCallback {
111111
// TODO get a different queue implementation
112112
private final ConcurrentLinkedQueue<Object> queue = new ConcurrentLinkedQueue<Object>();
113-
private final Long baseCapacity;
114113
private final AtomicLong capacity;
115114
private final Subscriber<? super T> child;
116115
private final AtomicBoolean saturated = new AtomicBoolean(false);
@@ -122,7 +121,6 @@ private static final class BufferSubscriber<T> extends Subscriber<T> implements
122121
public BufferSubscriber(final Subscriber<? super T> child, Long capacity, Action0 onOverflow,
123122
BackpressureOverflow.Strategy overflowStrategy) {
124123
this.child = child;
125-
this.baseCapacity = capacity;
126124
this.capacity = capacity != null ? new AtomicLong(capacity) : null;
127125
this.onOverflow = onOverflow;
128126
this.manager = new BackpressureDrainManager(this);

0 commit comments

Comments
 (0)