@@ -1370,8 +1370,8 @@ public void takeUntilSuccess() {
1370
1370
other .sendOnSuccess ("one" );
1371
1371
1372
1372
result .assertError (CancellationException .class );
1373
- verify (sSource , times ( 1 ) ).unsubscribe ();
1374
- verify (sOther , times ( 1 ) ).unsubscribe ();
1373
+ verify (sSource ).unsubscribe ();
1374
+ verify (sOther ).unsubscribe ();
1375
1375
}
1376
1376
1377
1377
@ Test
@@ -1388,8 +1388,8 @@ public void takeUntilSourceSuccess() {
1388
1388
source .sendOnSuccess ("one" );
1389
1389
1390
1390
result .assertValue ("one" );
1391
- verify (sSource , times ( 1 ) ).unsubscribe ();
1392
- verify (sOther , times ( 1 ) ).unsubscribe ();
1391
+ verify (sSource ).unsubscribe ();
1392
+ verify (sOther ).unsubscribe ();
1393
1393
}
1394
1394
1395
1395
@ Test
@@ -1406,8 +1406,8 @@ public void takeUntilNext() {
1406
1406
other .sendOnNext ("one" );
1407
1407
1408
1408
result .assertError (CancellationException .class );
1409
- verify (sSource , times ( 1 ) ).unsubscribe ();
1410
- verify (sOther , times ( 1 ) ).unsubscribe ();
1409
+ verify (sSource ).unsubscribe ();
1410
+ verify (sOther ).unsubscribe ();
1411
1411
}
1412
1412
1413
1413
@ Test
@@ -1424,8 +1424,8 @@ public void takeUntilSourceSuccessObservable() {
1424
1424
source .sendOnSuccess ("one" );
1425
1425
1426
1426
result .assertValue ("one" );
1427
- verify (sSource , times ( 1 ) ).unsubscribe ();
1428
- verify (sOther , times ( 1 ) ).unsubscribe ();
1427
+ verify (sSource ).unsubscribe ();
1428
+ verify (sOther ).unsubscribe ();
1429
1429
}
1430
1430
1431
1431
@ Test
@@ -1443,8 +1443,8 @@ public void takeUntilSourceError() {
1443
1443
source .sendOnError (error );
1444
1444
1445
1445
result .assertError (error );
1446
- verify (sSource , times ( 1 ) ).unsubscribe ();
1447
- verify (sOther , times ( 1 ) ).unsubscribe ();
1446
+ verify (sSource ).unsubscribe ();
1447
+ verify (sOther ).unsubscribe ();
1448
1448
}
1449
1449
1450
1450
@ Test
@@ -1462,8 +1462,8 @@ public void takeUntilSourceErrorObservable() {
1462
1462
source .sendOnError (error );
1463
1463
1464
1464
result .assertError (error );
1465
- verify (sSource , times ( 1 ) ).unsubscribe ();
1466
- verify (sOther , times ( 1 ) ).unsubscribe ();
1465
+ verify (sSource ).unsubscribe ();
1466
+ verify (sOther ).unsubscribe ();
1467
1467
}
1468
1468
1469
1469
@ Test
@@ -1481,8 +1481,8 @@ public void takeUntilOtherError() {
1481
1481
other .sendOnError (error );
1482
1482
1483
1483
result .assertError (error );
1484
- verify (sSource , times ( 1 ) ).unsubscribe ();
1485
- verify (sOther , times ( 1 ) ).unsubscribe ();
1484
+ verify (sSource ).unsubscribe ();
1485
+ verify (sOther ).unsubscribe ();
1486
1486
}
1487
1487
1488
1488
@ Test
@@ -1500,8 +1500,8 @@ public void takeUntilOtherErrorObservable() {
1500
1500
other .sendOnError (error );
1501
1501
1502
1502
result .assertError (error );
1503
- verify (sSource , times ( 1 ) ).unsubscribe ();
1504
- verify (sOther , times ( 1 ) ).unsubscribe ();
1503
+ verify (sSource ).unsubscribe ();
1504
+ verify (sOther ).unsubscribe ();
1505
1505
}
1506
1506
1507
1507
@ Test
@@ -1518,8 +1518,8 @@ public void takeUntilOtherCompleted() {
1518
1518
other .sendOnCompleted ();
1519
1519
1520
1520
result .assertError (CancellationException .class );
1521
- verify (sSource , times ( 1 ) ).unsubscribe ();
1522
- verify (sOther , times ( 1 ) ).unsubscribe ();
1521
+ verify (sSource ).unsubscribe ();
1522
+ verify (sOther ).unsubscribe ();
1523
1523
1524
1524
}
1525
1525
0 commit comments