File |
Project |
Line |
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueue.java |
rxjava-extras |
292 |
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueueMemoryMapped.java |
rxjava-extras |
146 |
}
@Override
public boolean contains(Object o) {
throw new UnsupportedOperationException();
}
@Override
public Iterator<T> iterator() {
throw new UnsupportedOperationException();
}
@Override
public Object[] toArray() {
throw new UnsupportedOperationException();
}
@SuppressWarnings("hiding")
@Override
public <T> T[] toArray(T[] a) {
throw new UnsupportedOperationException();
}
@Override
public boolean remove(Object o) {
throw new UnsupportedOperationException();
}
@Override
public boolean containsAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean addAll(Collection<? extends T> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean removeAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean retainAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public void clear() {
throw new UnsupportedOperationException();
} |
File |
Project |
Line |
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueue.java |
rxjava-extras |
290 |
com/github/davidmoten/rx/internal/operators/RollingSPSCQueue.java |
rxjava-extras |
205 |
public T remove() {
throw new UnsupportedOperationException();
}
@Override
public boolean contains(Object o) {
throw new UnsupportedOperationException();
}
@Override
public Iterator<T> iterator() {
throw new UnsupportedOperationException();
}
@Override
public Object[] toArray() {
throw new UnsupportedOperationException();
}
@SuppressWarnings("hiding")
@Override
public <T> T[] toArray(T[] a) {
throw new UnsupportedOperationException();
}
@Override
public boolean remove(Object o) {
throw new UnsupportedOperationException();
}
@Override
public boolean containsAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean addAll(Collection<? extends T> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean removeAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean retainAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public void clear() { |
File |
Project |
Line |
com/github/davidmoten/rx/internal/operators/FileBasedSPSCQueueMemoryMapped.java |
rxjava-extras |
146 |
com/github/davidmoten/rx/internal/operators/RollingSPSCQueue.java |
rxjava-extras |
207 |
}
@Override
public boolean contains(Object o) {
throw new UnsupportedOperationException();
}
@Override
public Iterator<T> iterator() {
throw new UnsupportedOperationException();
}
@Override
public Object[] toArray() {
throw new UnsupportedOperationException();
}
@SuppressWarnings("hiding")
@Override
public <T> T[] toArray(T[] a) {
throw new UnsupportedOperationException();
}
@Override
public boolean remove(Object o) {
throw new UnsupportedOperationException();
}
@Override
public boolean containsAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean addAll(Collection<? extends T> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean removeAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public boolean retainAll(Collection<?> c) {
throw new UnsupportedOperationException();
}
@Override
public void clear() { |
File |
Project |
Line |
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java |
rxjava-extras |
155 |
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java |
rxjava-extras |
277 |
public BoundedAfterSubscriber(Subscriber<? super List<T>> actual, int capacityHint,
Func1<? super T, Boolean> predicate, int prefetch) {
super(actual, capacityHint, predicate, prefetch);
}
@Override
void drain() {
if (wip.getAndIncrement() != 0) {
return;
}
final Subscriber<? super List<T>> localSubscriber = actual;
final Queue<Object> localQueue = queue;
int missed = 1;
for (;;) {
long localRequested = requested.get();
long localEmission = 0L;
long localConsumption = 0L;
List<T> localBuffer = buffer;
while (localEmission != localRequested) {
if (localSubscriber.isUnsubscribed()) {
return;
}
boolean mainDone = done;
if (mainDone) {
Throwable exception = error;
if (exception != null) {
buffer = null;
localSubscriber.onError(exception);
return;
}
}
Object notification = localQueue.poll(); |
File |
Project |
Line |
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java |
rxjava-extras |
231 |
com/github/davidmoten/rx/internal/operators/OperatorBufferPredicateBoundary.java |
rxjava-extras |
354 |
}
if (localEmission == localRequested) {
if (localSubscriber.isUnsubscribed()) {
return;
}
boolean mainDone = done;
if (mainDone) {
Throwable exception = error;
if (exception != null) {
buffer = null;
localSubscriber.onError(exception);
return;
} else
if (localQueue.isEmpty() && localBuffer.isEmpty()) {
buffer = null;
localSubscriber.onCompleted();
return;
}
}
}
if (localEmission != 0L) {
BackpressureUtils.produced(requested, localEmission);
}
if (localConsumption != 0L) {
long p = upstreamConsumed + localConsumption; |