26
26
27
27
import static org .mockito .Mockito .*;
28
28
29
- public class OperatorMulticast {
29
+ public class OperationMulticast {
30
30
public static <T , R > ConnectableObservable <R > multicast (Observable <T > source , final Subject <T , R > subject ) {
31
31
return new MulticastConnectableObservable <T , R >(source , subject );
32
32
}
@@ -95,7 +95,7 @@ public static class UnitTest {
95
95
public void testMulticast () {
96
96
TestObservable source = new TestObservable ();
97
97
98
- ConnectableObservable <String > multicasted = OperatorMulticast .multicast (source ,
98
+ ConnectableObservable <String > multicasted = OperationMulticast .multicast (source ,
99
99
PublishSubject .<String >create ());
100
100
101
101
Observer <String > observer = mock (Observer .class );
@@ -122,7 +122,7 @@ public void testMulticast() {
122
122
public void testMulticastConnectTwice () {
123
123
TestObservable source = new TestObservable ();
124
124
125
- ConnectableObservable <String > multicasted = OperatorMulticast .multicast (source ,
125
+ ConnectableObservable <String > multicasted = OperationMulticast .multicast (source ,
126
126
PublishSubject .<String >create ());
127
127
128
128
Observer <String > observer = mock (Observer .class );
@@ -146,7 +146,7 @@ public void testMulticastConnectTwice() {
146
146
public void testMulticastDisconnect () {
147
147
TestObservable source = new TestObservable ();
148
148
149
- ConnectableObservable <String > multicasted = OperatorMulticast .multicast (source ,
149
+ ConnectableObservable <String > multicasted = OperationMulticast .multicast (source ,
150
150
PublishSubject .<String >create ());
151
151
152
152
Observer <String > observer = mock (Observer .class );
0 commit comments