Skip to content

Commit eaf146a

Browse files
authored
1.x: header and whitespace cleanup (ReactiveX#4949)
1 parent 6de5c6f commit eaf146a

File tree

6 files changed

+54
-6
lines changed

6 files changed

+54
-6
lines changed

src/main/java/rx/internal/schedulers/SchedulePeriodicHelper.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,15 +45,15 @@ private SchedulePeriodicHelper() {
4545
}
4646

4747
/**
48-
* Return the current time in nanoseconds.
48+
* Return the current time in nanoseconds.
4949
*/
5050
public interface NowNanoSupplier {
5151
long nowNanos();
5252
}
5353

5454
public static Subscription schedulePeriodically(
5555
final Worker worker,
56-
final Action0 action,
56+
final Action0 action,
5757
long initialDelay, long period, TimeUnit unit,
5858
final NowNanoSupplier nowNanoSupplier) {
5959
final long periodInNanos = unit.toNanos(period);

src/main/java/rx/internal/subscriptions/CancellableSubscription.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,19 @@
1+
/**
2+
* Copyright 2016 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+
*/
16+
117
package rx.internal.subscriptions;
218

319
import java.util.concurrent.atomic.AtomicReference;

src/main/java/rx/schedulers/TestScheduler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -176,15 +176,15 @@ public void call() {
176176

177177
@Override
178178
public Subscription schedulePeriodically(Action0 action, long initialDelay, long period, TimeUnit unit) {
179-
return SchedulePeriodicHelper.schedulePeriodically(this,
179+
return SchedulePeriodicHelper.schedulePeriodically(this,
180180
action, initialDelay, period, unit, this);
181181
}
182-
182+
183183
@Override
184184
public long now() {
185185
return TestScheduler.this.now();
186186
}
187-
187+
188188
@Override
189189
public long nowNanos() {
190190
return TestScheduler.this.time;

src/test/java/rx/internal/operators/CompletableConcatTest.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,19 @@
1+
/**
2+
* Copyright 2016 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+
*/
16+
117
package rx.internal.operators;
218

319
import java.util.concurrent.TimeUnit;

src/test/java/rx/internal/operators/CompletableMergeTest.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,19 @@
1+
/**
2+
* Copyright 2016 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+
*/
16+
117
package rx.internal.operators;
218

319
import java.util.concurrent.TimeUnit;

src/test/java/rx/schedulers/TestSchedulerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ public void call() {
215215
inner.unsubscribe();
216216
}
217217
}
218-
218+
219219
@Test
220220
public void resolution() {
221221
for (final TimeUnit unit : TimeUnit.values()) {

0 commit comments

Comments
 (0)