File tree 1 file changed +13
-18
lines changed
src/test/java/io/reactivex/plugins
1 file changed +13
-18
lines changed Original file line number Diff line number Diff line change @@ -1891,27 +1891,22 @@ public void accept(final Throwable throwable) throws Exception {
1891
1891
1892
1892
private static void verifyThread (Worker w , Predicate <Thread > threadPredicate ) {
1893
1893
try {
1894
- try {
1895
- final AtomicReference <Thread > value = new AtomicReference <>();
1896
- final CountDownLatch cdl = new CountDownLatch (1 );
1897
-
1898
- w .schedule (new Runnable () {
1899
- @ Override
1900
- public void run () {
1901
- value .set (Thread .currentThread ());
1902
- cdl .countDown ();
1903
- }
1904
- });
1894
+ final AtomicReference <Thread > value = new AtomicReference <Thread >();
1895
+ final CountDownLatch cdl = new CountDownLatch (1 );
1905
1896
1906
- cdl .await ();
1897
+ w .schedule (new Runnable () {
1898
+ @ Override
1899
+ public void run () {
1900
+ value .set (Thread .currentThread ());
1901
+ cdl .countDown ();
1902
+ }
1903
+ });
1907
1904
1908
- Thread t = value .get ();
1909
- assertNotNull (t );
1910
- assertTrue (threadPredicate .test (t ));
1905
+ cdl .await ();
1911
1906
1912
- } catch ( Exception e ) {
1913
- fail ( );
1914
- }
1907
+ Thread t = value . get ();
1908
+ assertNotNull ( t );
1909
+ assertTrue ( threadPredicate . test ( t ));
1915
1910
} catch (Exception e ) {
1916
1911
fail ();
1917
1912
} finally {
You can’t perform that action at this time.
0 commit comments