Skip to content

Commit

Permalink
2.x: fix whitespaces
Browse files Browse the repository at this point in the history
  • Loading branch information
akarnokd committed Apr 2, 2017
1 parent 83d1a4f commit a0bfaa2
Show file tree
Hide file tree
Showing 6 changed files with 9 additions and 9 deletions.
2 changes: 1 addition & 1 deletion src/main/java/io/reactivex/flowables/GroupedFlowable.java
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
* @see <a href="http://reactivex.io/documentation/operators/groupby.html">ReactiveX documentation: GroupBy</a>
*/
public abstract class GroupedFlowable<K, T> extends Flowable<T> {

final K key;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
* @see <a href="http://reactivex.io/documentation/operators/groupby.html">ReactiveX documentation: GroupBy</a>
*/
public abstract class GroupedObservable<K, T> extends Observable<T> {

final K key;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@
* @param <T> the received value type
*/
public abstract class DisposableMaybeObserver<T> implements MaybeObserver<T>, Disposable {

final AtomicReference<Disposable> s = new AtomicReference<Disposable>();

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@
* @param <T> the received value type
*/
public abstract class DisposableObserver<T> implements Observer<T>, Disposable {

final AtomicReference<Disposable> s = new AtomicReference<Disposable>();

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@
* @param <T> the received value type
*/
public abstract class DisposableSingleObserver<T> implements SingleObserver<T>, Disposable {

final AtomicReference<Disposable> s = new AtomicReference<Disposable>();

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,22 +33,22 @@ public void hashCodeOf() {
}

@Test
public void verifyPositiveInt() throws Exception{
public void verifyPositiveInt() throws Exception {
assertEquals(1, ObjectHelper.verifyPositive(1, "param"));
}

@Test
public void verifyPositiveLong() throws Exception{
public void verifyPositiveLong() throws Exception {
assertEquals(1L, ObjectHelper.verifyPositive(1L, "param"));
}

@Test(expected = IllegalArgumentException.class)
public void verifyPositiveIntFail() throws Exception{
public void verifyPositiveIntFail() throws Exception {
assertEquals(-1, ObjectHelper.verifyPositive(-1, "param"));
}

@Test(expected = IllegalArgumentException.class)
public void verifyPositiveLongFail() throws Exception{
public void verifyPositiveLongFail() throws Exception {
assertEquals(-1L, ObjectHelper.verifyPositive(-1L, "param"));
}

Expand Down

0 comments on commit a0bfaa2

Please sign in to comment.