File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
src/main/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -114,8 +114,9 @@ public void onStart() {
114
114
115
115
private void requestFromChild (long n ) {
116
116
// we track 'requested' so we know whether we should subscribe the next or not
117
+ ConcatInnerSubscriber <T > actualSubscriber = currentSubscriber ;
117
118
if (REQUESTED_UPDATER .getAndAdd (this , n ) == 0 ) {
118
- if (currentSubscriber == null && wip > 0 ) {
119
+ if (actualSubscriber == null && wip > 0 ) {
119
120
// this means we may be moving from one subscriber to another after having stopped processing
120
121
// so need to kick off the subscribe via this request notification
121
122
subscribeNext ();
@@ -124,9 +125,9 @@ private void requestFromChild(long n) {
124
125
}
125
126
}
126
127
127
- if (currentSubscriber != null ) {
128
+ if (actualSubscriber != null ) {
128
129
// otherwise we are just passing it through to the currentSubscriber
129
- currentSubscriber .requestMore (n );
130
+ actualSubscriber .requestMore (n );
130
131
}
131
132
}
132
133
You can’t perform that action at this time.
0 commit comments