File tree 1 file changed +2
-3
lines changed
rxjava-core/src/main/java/rx/subjects
1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 1
1
package rx .subjects ;
2
2
3
- import groovy .lang .Reference ;
4
-
5
3
import java .util .ArrayList ;
6
4
import java .util .List ;
7
5
import java .util .concurrent .ConcurrentHashMap ;
8
6
import java .util .concurrent .atomic .AtomicBoolean ;
7
+ import java .util .concurrent .atomic .AtomicReference ;
9
8
10
9
import junit .framework .Assert ;
11
10
@@ -78,7 +77,7 @@ public static class UnitTest {
78
77
@ Test
79
78
public void test () {
80
79
Subject <Integer > subject = Subject .<Integer > create ();
81
- final Reference <List <Notification <String >>> actualRef = new Reference <List <Notification <String >>>();
80
+ final AtomicReference <List <Notification <String >>> actualRef = new AtomicReference <List <Notification <String >>>();
82
81
83
82
Observable <List <Notification <Integer >>> wNotificationsList = subject .materialize ().toList ();
84
83
wNotificationsList .subscribe (new Action1 <List <Notification <String >>>() {
You can’t perform that action at this time.
0 commit comments