File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -111,7 +111,7 @@ public Observable<? extends Notification<?>> call(Observable<? extends Notificat
111111 @ Override
112112 public Notification <Integer > call (Notification <Integer > n , Notification <?> term ) {
113113 final int value = n .getValue ();
114- if (predicate .call (value , term .getThrowable ()). booleanValue () )
114+ if (predicate .call (value , term .getThrowable ()))
115115 return Notification .createOnNext (value + 1 );
116116 else
117117 return (Notification <Integer >) term ;
Original file line number Diff line number Diff line change @@ -805,7 +805,7 @@ public void replay(InnerProducer<T> output) {
805805 int sourceIndex = size ;
806806
807807 Integer destIndexObject = output .index ();
808- int destIndex = destIndexObject != null ? destIndexObject . intValue () : 0 ;
808+ int destIndex = destIndexObject != null ? destIndexObject : 0 ;
809809
810810 long r = output .get ();
811811 long r0 = r ;
Original file line number Diff line number Diff line change @@ -57,9 +57,9 @@ private static class CompareActionsByTime implements Comparator<TimedAction> {
5757 @ Override
5858 public int compare (TimedAction action1 , TimedAction action2 ) {
5959 if (action1 .time == action2 .time ) {
60- return Long .valueOf (action1 .count ).compareTo (Long . valueOf ( action2 .count ) );
60+ return Long .valueOf (action1 .count ).compareTo (action2 .count );
6161 } else {
62- return Long .valueOf (action1 .time ).compareTo (Long . valueOf ( action2 .time ) );
62+ return Long .valueOf (action1 .time ).compareTo (action2 .time );
6363 }
6464 }
6565 }
You can’t perform that action at this time.
0 commit comments