@@ -148,7 +148,7 @@ public void itForwardsOnErrorToTargetObserver() {
148
148
public void itDropsOnNextOnCompletedSequenceIfTargetComponentIsGone () throws Throwable {
149
149
PublishSubject <Integer > source = PublishSubject .create ();
150
150
151
- final Observable .OnSubscribeFunc <Integer > operator = newOnSubscribeFragmentInstance (source , mockFragment );
151
+ final Observable .OnSubscribeFunc <Integer > operator = newOnSubscribeFragmentInstance (source . toObservable () , mockFragment );
152
152
operator .onSubscribe (mockObserver );
153
153
154
154
source .onNext (1 );
@@ -166,7 +166,7 @@ public void itDropsOnNextOnCompletedSequenceIfTargetComponentIsGone() throws Thr
166
166
public void itDropsOnErrorIfTargetComponentIsGone () throws Throwable {
167
167
PublishSubject <Integer > source = PublishSubject .create ();
168
168
169
- final Observable .OnSubscribeFunc <Integer > operator = newOnSubscribeFragmentInstance (source , mockFragment );
169
+ final Observable .OnSubscribeFunc <Integer > operator = newOnSubscribeFragmentInstance (source . toObservable () , mockFragment );
170
170
operator .onSubscribe (mockObserver );
171
171
172
172
source .onNext (1 );
@@ -202,7 +202,7 @@ private void releaseComponentRef(Observable.OnSubscribeFunc<Integer> operator) t
202
202
@ Test
203
203
public void itDoesNotForwardOnNextOnCompletedSequenceIfFragmentIsDetached () {
204
204
PublishSubject <Integer > source = PublishSubject .create ();
205
- OperationObserveFromAndroidComponent .observeFromAndroidComponent (source , mockFragment ).subscribe (mockObserver );
205
+ OperationObserveFromAndroidComponent .observeFromAndroidComponent (source . toObservable () , mockFragment ).subscribe (mockObserver );
206
206
207
207
source .onNext (1 );
208
208
@@ -218,7 +218,7 @@ public void itDoesNotForwardOnNextOnCompletedSequenceIfFragmentIsDetached() {
218
218
@ Test
219
219
public void itDoesNotForwardOnErrorIfFragmentIsDetached () {
220
220
PublishSubject <Integer > source = PublishSubject .create ();
221
- OperationObserveFromAndroidComponent .observeFromAndroidComponent (source , mockFragment ).subscribe (mockObserver );
221
+ OperationObserveFromAndroidComponent .observeFromAndroidComponent (source . toObservable () , mockFragment ).subscribe (mockObserver );
222
222
223
223
source .onNext (1 );
224
224
0 commit comments