in benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/FlowableCharSequence.java [80:117]
void slowPath(long r) {
long e = 0L;
int i = index;
int f = end;
CharSequence s = string;
Subscriber<? super Integer> a = downstream;
for (;;) {
while (e != r && i != f) {
if (cancelled) {
return;
}
a.onNext((int)s.charAt(i));
i++;
e++;
}
if (i == f) {
if (!cancelled) {
a.onComplete();
}
return;
}
r = get();
if (e == r) {
index = i;
r = addAndGet(-e);
if (r == 0L) {
break;
}
e = 0L;
}
}
}