We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 9fb979c + 6142378 commit e44e7ecCopy full SHA for e44e7ec
src/main/java/rx/internal/operators/OnSubscribeCombineLatest.java
@@ -138,7 +138,6 @@ public void request(long n) {
138
* This will only allow one thread at a time to do the work, but ensures via `counter` increment/decrement
139
* that there is always once who acts on each `tick`. Same concept as used in OperationObserveOn.
140
*/
141
- @SuppressWarnings("unchecked")
142
void tick() {
143
if (WIP.getAndIncrement(this) == 0) {
144
int emitted = 0;
@@ -150,7 +149,7 @@ void tick() {
150
149
if (buffer.isCompleted(o)) {
151
child.onCompleted();
152
} else {
153
- child.onNext(NotificationLite.<R>instance().getValue(o));
+ buffer.accept(o, child);
154
emitted++;
155
requested.decrementAndGet();
156
}
0 commit comments