File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
rxjava-core/src/main/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change 2121import rx .Observer ;
2222import rx .Subscriber ;
2323import rx .functions .Action0 ;
24+ import rx .observers .EmptyObserver ;
2425import rx .observers .Subscribers ;
2526import rx .subjects .Subject ;
2627import rx .subscriptions .Subscriptions ;
5051 */
5152public class BufferUntilSubscriber <T > extends Subject <T , T > {
5253
54+ @ SuppressWarnings ("rawtypes" )
55+ private final static Observer EMPTY_OBSERVER = new EmptyObserver ();
56+
5357 /**
5458 * @warn create() undescribed
5559 * @return
@@ -92,7 +96,7 @@ public void call(final Subscriber<? super T> s) {
9296 s .add (Subscriptions .create (new Action0 () {
9397 @ Override
9498 public void call () {
95- state .observerRef = Subscribers . empty () ;
99+ state .observerRef = EMPTY_OBSERVER ;
96100 }
97101 }));
98102 boolean win = false ;
You can’t perform that action at this time.
0 commit comments