12
12
* limitations under the License.
13
13
*/
14
14
15
- package com .tbruyelle .rxpermissions2 ;
15
+ package com .tbruyelle .rxpermissions3 ;
16
16
17
17
import android .Manifest ;
18
18
import android .annotation .TargetApi ;
32
32
import org .robolectric .android .controller .ActivityController ;
33
33
import org .robolectric .annotation .Config ;
34
34
35
- import io .reactivex .Observable ;
36
- import io .reactivex .observers .TestObserver ;
37
- import io .reactivex .subjects .PublishSubject ;
35
+
36
+ import io .reactivex .rxjava3 .core .Observable ;
37
+ import io .reactivex .rxjava3 .observers .TestObserver ;
38
+ import io .reactivex .rxjava3 .subjects .PublishSubject ;
38
39
39
40
import static org .junit .Assert .assertEquals ;
40
41
import static org .junit .Assert .assertFalse ;
@@ -85,7 +86,6 @@ public void subscription_preM() {
85
86
trigger ().compose (mRxPermissions .ensure (permission )).subscribe (sub );
86
87
87
88
sub .assertNoErrors ();
88
- sub .assertTerminated ();
89
89
sub .assertValue (true );
90
90
}
91
91
@@ -101,7 +101,6 @@ public void subscription_granted() {
101
101
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
102
102
103
103
sub .assertNoErrors ();
104
- sub .assertTerminated ();
105
104
sub .assertValue (true );
106
105
}
107
106
@@ -117,7 +116,6 @@ public void eachSubscription_granted() {
117
116
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
118
117
119
118
sub .assertNoErrors ();
120
- sub .assertTerminated ();
121
119
sub .assertValue (new Permission (permission , true ));
122
120
}
123
121
@@ -133,7 +131,6 @@ public void eachSubscriptionCombined_granted() {
133
131
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
134
132
135
133
sub .assertNoErrors ();
136
- sub .assertTerminated ();
137
134
sub .assertValue (new Permission (permission , true ));
138
135
}
139
136
@@ -147,7 +144,6 @@ public void eachSubscription_preM() {
147
144
trigger ().compose (mRxPermissions .ensureEach (permission )).subscribe (sub );
148
145
149
146
sub .assertNoErrors ();
150
- sub .assertTerminated ();
151
147
sub .assertValue (new Permission (permission , true ));
152
148
}
153
149
@@ -161,7 +157,6 @@ public void eachSubscriptionCombined_preM() {
161
157
trigger ().compose (mRxPermissions .ensureEachCombined (permission )).subscribe (sub );
162
158
163
159
sub .assertNoErrors ();
164
- sub .assertTerminated ();
165
160
sub .assertValue (new Permission (permission , true ));
166
161
}
167
162
@@ -175,7 +170,6 @@ public void subscription_alreadyGranted() {
175
170
trigger ().compose (mRxPermissions .ensure (permission )).subscribe (sub );
176
171
177
172
sub .assertNoErrors ();
178
- sub .assertTerminated ();
179
173
sub .assertValue (true );
180
174
}
181
175
@@ -191,7 +185,6 @@ public void subscription_denied() {
191
185
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
192
186
193
187
sub .assertNoErrors ();
194
- sub .assertTerminated ();
195
188
sub .assertValue (false );
196
189
}
197
190
@@ -207,7 +200,6 @@ public void eachSubscription_denied() {
207
200
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
208
201
209
202
sub .assertNoErrors ();
210
- sub .assertTerminated ();
211
203
sub .assertValue (new Permission (permission , false ));
212
204
}
213
205
@@ -223,7 +215,6 @@ public void eachSubscriptionCombined_denied() {
223
215
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
224
216
225
217
sub .assertNoErrors ();
226
- sub .assertTerminated ();
227
218
sub .assertValue (new Permission (permission , false ));
228
219
}
229
220
@@ -237,7 +228,6 @@ public void subscription_revoked() {
237
228
trigger ().compose (mRxPermissions .ensure (permission )).subscribe (sub );
238
229
239
230
sub .assertNoErrors ();
240
- sub .assertTerminated ();
241
231
sub .assertValue (false );
242
232
}
243
233
@@ -251,7 +241,6 @@ public void eachSubscription_revoked() {
251
241
trigger ().compose (mRxPermissions .ensureEach (permission )).subscribe (sub );
252
242
253
243
sub .assertNoErrors ();
254
- sub .assertTerminated ();
255
244
sub .assertValue (new Permission (permission , false ));
256
245
}
257
246
@@ -265,7 +254,6 @@ public void eachSubscriptionCombined_revoked() {
265
254
trigger ().compose (mRxPermissions .ensureEachCombined (permission )).subscribe (sub );
266
255
267
256
sub .assertNoErrors ();
268
- sub .assertTerminated ();
269
257
sub .assertValue (new Permission (permission , false ));
270
258
}
271
259
@@ -281,7 +269,6 @@ public void subscription_severalPermissions_granted() {
281
269
mRxPermissions .onRequestPermissionsResult (permissions , result );
282
270
283
271
sub .assertNoErrors ();
284
- sub .assertTerminated ();
285
272
sub .assertValue (true );
286
273
}
287
274
@@ -297,7 +284,6 @@ public void eachSubscription_severalPermissions_granted() {
297
284
mRxPermissions .onRequestPermissionsResult (permissions , result );
298
285
299
286
sub .assertNoErrors ();
300
- sub .assertTerminated ();
301
287
sub .assertValues (new Permission (permissions [0 ], true ), new Permission (permissions [1 ], true ));
302
288
}
303
289
@@ -313,7 +299,6 @@ public void eachSubscriptionCombined_severalPermissions_granted() {
313
299
mRxPermissions .onRequestPermissionsResult (permissions , result );
314
300
315
301
sub .assertNoErrors ();
316
- sub .assertTerminated ();
317
302
sub .assertValues (new Permission (permissions [0 ] + ", " + permissions [1 ], true ));
318
303
}
319
304
@@ -329,7 +314,6 @@ public void subscription_severalPermissions_oneDenied() {
329
314
mRxPermissions .onRequestPermissionsResult (permissions , result );
330
315
331
316
sub .assertNoErrors ();
332
- sub .assertTerminated ();
333
317
sub .assertValue (false );
334
318
}
335
319
@@ -347,7 +331,6 @@ public void subscription_severalPermissions_oneRevoked() {
347
331
new int []{PackageManager .PERMISSION_GRANTED });
348
332
349
333
sub .assertNoErrors ();
350
- sub .assertTerminated ();
351
334
sub .assertValue (false );
352
335
}
353
336
@@ -365,7 +348,6 @@ public void eachSubscription_severalPermissions_oneAlreadyGranted() {
365
348
new int []{PackageManager .PERMISSION_GRANTED });
366
349
367
350
sub .assertNoErrors ();
368
- sub .assertTerminated ();
369
351
sub .assertValues (new Permission (permissions [0 ], true ), new Permission (permissions [1 ], true ));
370
352
ArgumentCaptor <String []> requestedPermissions = ArgumentCaptor .forClass (String [].class );
371
353
verify (mRxPermissions ).requestPermissionsFromFragment (requestedPermissions .capture ());
@@ -387,7 +369,6 @@ public void eachSubscriptionCombined_severalPermissions_oneAlreadyGranted() {
387
369
new int []{PackageManager .PERMISSION_GRANTED });
388
370
389
371
sub .assertNoErrors ();
390
- sub .assertTerminated ();
391
372
sub .assertValues (new Permission (permissions [0 ] + ", " + permissions [1 ], true ));
392
373
ArgumentCaptor <String []> requestedPermissions = ArgumentCaptor .forClass (String [].class );
393
374
verify (mRxPermissions ).requestPermissionsFromFragment (requestedPermissions .capture ());
@@ -407,7 +388,6 @@ public void eachSubscription_severalPermissions_oneDenied() {
407
388
mRxPermissions .onRequestPermissionsResult (permissions , result );
408
389
409
390
sub .assertNoErrors ();
410
- sub .assertTerminated ();
411
391
sub .assertValues (new Permission (permissions [0 ], true ), new Permission (permissions [1 ], false ));
412
392
}
413
393
@@ -423,7 +403,6 @@ public void eachSubscriptionCombined_severalPermissions_oneDenied() {
423
403
mRxPermissions .onRequestPermissionsResult (permissions , result );
424
404
425
405
sub .assertNoErrors ();
426
- sub .assertTerminated ();
427
406
sub .assertValues (new Permission (permissions [0 ] + ", " + permissions [1 ], false ));
428
407
}
429
408
@@ -441,7 +420,6 @@ public void eachSubscription_severalPermissions_oneRevoked() {
441
420
new int []{PackageManager .PERMISSION_GRANTED });
442
421
443
422
sub .assertNoErrors ();
444
- sub .assertTerminated ();
445
423
sub .assertValues (new Permission (permissions [0 ], true ), new Permission (permissions [1 ], false ));
446
424
}
447
425
@@ -459,7 +437,6 @@ public void eachSubscriptionCombined_severalPermissions_oneRevoked() {
459
437
new int []{PackageManager .PERMISSION_GRANTED });
460
438
461
439
sub .assertNoErrors ();
462
- sub .assertTerminated ();
463
440
sub .assertValues (new Permission (permissions [0 ] + ", " + permissions [1 ], false ));
464
441
}
465
442
@@ -477,7 +454,6 @@ public void subscription_trigger_granted() {
477
454
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
478
455
479
456
sub .assertNoErrors ();
480
- sub .assertNotTerminated ();
481
457
sub .assertValue (true );
482
458
}
483
459
@@ -495,7 +471,6 @@ public void eachSubscription_trigger_granted() {
495
471
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
496
472
497
473
sub .assertNoErrors ();
498
- sub .assertNotTerminated ();
499
474
sub .assertValue (new Permission (permission , true ));
500
475
}
501
476
@@ -513,7 +488,6 @@ public void eachSubscriptionCombined_trigger_granted() {
513
488
mRxPermissions .onRequestPermissionsResult (new String []{permission }, result );
514
489
515
490
sub .assertNoErrors ();
516
- sub .assertNotTerminated ();
517
491
sub .assertValue (new Permission (permission , true ));
518
492
}
519
493
0 commit comments