Skip to content

Commit dba5de9

Browse files
License Header and Separate out Perf Tests
1 parent 6b036e8 commit dba5de9

File tree

1 file changed

+19
-4
lines changed

1 file changed

+19
-4
lines changed

rxjava-core/src/test/java/rx/subjects/ReplaySubjectPerformanceAndConcurrencyTest.java renamed to rxjava-core/src/test/java/rx/subjects/ReplaySubjectConcurrencyTest.java

Lines changed: 19 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,18 @@
1+
/**
2+
* Copyright 2013 Netflix, Inc.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
116
package rx.subjects;
217

318
import static org.junit.Assert.*;
@@ -18,14 +33,14 @@
1833
import rx.subscriptions.Subscriptions;
1934
import rx.util.functions.Action1;
2035

21-
public class ReplaySubjectPerformanceAndConcurrencyTest {
36+
public class ReplaySubjectConcurrencyTest {
2237

2338
public static void main(String args[]) {
2439
try {
2540
for (int i = 0; i < 100; i++) {
26-
new ReplaySubjectPerformanceAndConcurrencyTest().testSubscribeCompletionRaceCondition();
27-
new ReplaySubjectPerformanceAndConcurrencyTest().testReplaySubjectConcurrentSubscriptions();
28-
new ReplaySubjectPerformanceAndConcurrencyTest().testReplaySubjectConcurrentSubscribersDoingReplayDontBlockEachOther();
41+
new ReplaySubjectConcurrencyTest().testSubscribeCompletionRaceCondition();
42+
new ReplaySubjectConcurrencyTest().testReplaySubjectConcurrentSubscriptions();
43+
new ReplaySubjectConcurrencyTest().testReplaySubjectConcurrentSubscribersDoingReplayDontBlockEachOther();
2944
}
3045
} catch (InterruptedException e) {
3146
e.printStackTrace();

0 commit comments

Comments
 (0)