Skip to content

Commit

Permalink
Merge branch 'master' of github.com:yegor256/cactoos
Browse files Browse the repository at this point in the history
  • Loading branch information
yegor256 committed Aug 6, 2017
2 parents 10d201e + f5d6b13 commit 7fab56e
Show file tree
Hide file tree
Showing 15 changed files with 80 additions and 79 deletions.
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/BoolOf.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ public final class BoolOf implements Scalar<Boolean> {
/**
* Source text.
*/
private final Text text;
private final Text origin;

/**
* Ctor.
Expand All @@ -59,11 +59,11 @@ public BoolOf(final String string) {
* @param text True or false text
*/
public BoolOf(final Text text) {
this.text = text;
this.origin = text;
}

@Override
public Boolean value() throws IOException {
return Boolean.valueOf(this.text.asString());
return Boolean.valueOf(this.origin.asString());
}
}
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/DoubleOf.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ public final class DoubleOf implements Scalar<Double> {
/**
* Source text.
*/
private final Text text;
private final Text origin;

/**
* Ctor.
Expand All @@ -59,11 +59,11 @@ public DoubleOf(final String string) {
* @param text Number-text
*/
public DoubleOf(final Text text) {
this.text = text;
this.origin = text;
}

@Override
public Double value() throws IOException {
return Double.valueOf(this.text.asString());
return Double.valueOf(this.origin.asString());
}
}
10 changes: 5 additions & 5 deletions src/main/java/org/cactoos/scalar/Equals.java
Original file line number Diff line number Diff line change
Expand Up @@ -49,12 +49,12 @@ public final class Equals<T extends Comparable<T>> implements Scalar<Boolean> {

/**
* Ctor.
* @param frst The first scalar to compare.
* @param scnd The second scalar to compare.
* @param source The first scalar to compare.
* @param compared The second scalar to compare.
*/
public Equals(final Scalar<T> frst, final Scalar<T> scnd) {
this.first = frst;
this.second = scnd;
public Equals(final Scalar<T> source, final Scalar<T> compared) {
this.first = source;
this.second = compared;
}

@Override
Expand Down
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/FloatOf.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ public final class FloatOf implements Scalar<Float> {
/**
* Source text.
*/
private final Text text;
private final Text origin;

/**
* Ctor.
Expand All @@ -59,11 +59,11 @@ public FloatOf(final String string) {
* @param text Number-text
*/
public FloatOf(final Text text) {
this.text = text;
this.origin = text;
}

@Override
public Float value() throws IOException {
return Float.valueOf(this.text.asString());
return Float.valueOf(this.origin.asString());
}
}
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/IntOf.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ public final class IntOf implements Scalar<Integer> {
/**
* Source text.
*/
private final Text text;
private final Text origin;

/**
* Ctor.
Expand All @@ -59,11 +59,11 @@ public IntOf(final String string) {
* @param text Number-text
*/
public IntOf(final Text text) {
this.text = text;
this.origin = text;
}

@Override
public Integer value() throws IOException {
return Integer.valueOf(this.text.asString());
return Integer.valueOf(this.origin.asString());
}
}
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/IoCheckedScalar.java
Original file line number Diff line number Diff line change
Expand Up @@ -43,21 +43,21 @@ public final class IoCheckedScalar<T> implements Scalar<T> {
/**
* Original scalar.
*/
private final Scalar<T> scalar;
private final Scalar<T> origin;

/**
* Ctor.
* @param scalar Encapsulated scalar
*/
public IoCheckedScalar(final Scalar<T> scalar) {
this.scalar = scalar;
this.origin = scalar;
}

@Override
public T value() throws IOException {
return new IoCheckedFunc<Scalar<T>, T>(
Scalar::value
).apply(this.scalar);
).apply(this.origin);
}

}
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/LongOf.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ public final class LongOf implements Scalar<Long> {
/**
* Source text.
*/
private final Text text;
private final Text origin;

/**
* Ctor.
Expand All @@ -59,11 +59,11 @@ public LongOf(final String string) {
* @param text Number-text
*/
public LongOf(final Text text) {
this.text = text;
this.origin = text;
}

@Override
public Long value() throws IOException {
return Long.valueOf(this.text.asString());
return Long.valueOf(this.origin.asString());
}
}
12 changes: 6 additions & 6 deletions src/main/java/org/cactoos/scalar/Max.java
Original file line number Diff line number Diff line change
Expand Up @@ -47,19 +47,19 @@ public final class Max<T extends Comparable<T>> implements Scalar<T> {

/**
* Ctor.
* @param items The items
* @param scalars The items
*/
@SafeVarargs
public Max(final Scalar<T>... items) {
this(new IterableOf<>(items));
public Max(final Scalar<T>... scalars) {
this(new IterableOf<>(scalars));
}

/**
* Ctor.
* @param items The items
* @param iterable The items
*/
public Max(final Iterable<Scalar<T>> items) {
this.items = items;
public Max(final Iterable<Scalar<T>> iterable) {
this.items = iterable;
}

@Override
Expand Down
12 changes: 6 additions & 6 deletions src/main/java/org/cactoos/scalar/Min.java
Original file line number Diff line number Diff line change
Expand Up @@ -47,19 +47,19 @@ public final class Min<T extends Comparable<T>> implements Scalar<T> {

/**
* Ctor.
* @param items The items
* @param scalars The items
*/
@SafeVarargs
public Min(final Scalar<T>... items) {
this(new IterableOf<>(items));
public Min(final Scalar<T>... scalars) {
this(new IterableOf<>(scalars));
}

/**
* Ctor.
* @param items The items
* @param iterable The items
*/
public Min(final Iterable<Scalar<T>> items) {
this.items = items;
public Min(final Iterable<Scalar<T>> iterable) {
this.items = iterable;
}

@Override
Expand Down
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/Not.java
Original file line number Diff line number Diff line change
Expand Up @@ -43,10 +43,10 @@ public final class Not implements Scalar<Boolean> {

/**
* Ctor.
* @param origin The scalar
* @param scalar The scalar
*/
public Not(final Scalar<Boolean> origin) {
this.origin = origin;
public Not(final Scalar<Boolean> scalar) {
this.origin = scalar;
}

@Override
Expand Down
16 changes: 8 additions & 8 deletions src/main/java/org/cactoos/scalar/Or.java
Original file line number Diff line number Diff line change
Expand Up @@ -40,29 +40,29 @@ public final class Or implements Scalar<Boolean> {
/**
* The iterator.
*/
private final Iterable<Scalar<Boolean>> iterable;
private final Iterable<Scalar<Boolean>> origin;

/**
* Ctor.
* @param src The iterable
* @param scalar The Scalar.
*/
@SafeVarargs
public Or(final Scalar<Boolean>... src) {
this(new IterableOf<>(src));
public Or(final Scalar<Boolean>... scalar) {
this(new IterableOf<>(scalar));
}

/**
* Ctor.
* @param src The iterable
* @param iterable The iterable.
*/
public Or(final Iterable<Scalar<Boolean>> src) {
this.iterable = src;
public Or(final Iterable<Scalar<Boolean>> iterable) {
this.origin = iterable;
}

@Override
public Boolean value() throws Exception {
boolean result = false;
for (final Scalar<Boolean> item : this.iterable) {
for (final Scalar<Boolean> item : this.origin) {
if (item.value()) {
result = true;
break;
Expand Down
31 changes: 16 additions & 15 deletions src/main/java/org/cactoos/scalar/RetryScalar.java
Original file line number Diff line number Diff line change
Expand Up @@ -42,46 +42,47 @@ public final class RetryScalar<T> implements Scalar<T> {
/**
* Original scalar.
*/
private final Scalar<T> scalar;
private final Scalar<T> origin;

/**
* Exit condition.
*/
private final Func<Integer, Boolean> exit;
private final Func<Integer, Boolean> func;

/**
* Ctor.
* @param slr Scalar original
* @param scalar Scalar original
*/
public RetryScalar(final Scalar<T> slr) {
public RetryScalar(final Scalar<T> scalar) {
// @checkstyle MagicNumberCheck (1 line)
this(slr, 3);
this(scalar, 3);
}

/**
* Ctor.
* @param slr Scalar original
* @param scalar Scalar original
* @param attempts Maximum number of attempts
*/
public RetryScalar(final Scalar<T> slr, final int attempts) {
this(slr, attempt -> attempt >= attempts);
public RetryScalar(final Scalar<T> scalar, final int attempts) {
this(scalar, attempt -> attempt >= attempts);
}

/**
* Ctor.
* @param slr Func original
* @param ext Exit condition, returns TRUE if there is no more reason to try
* @param scalar Func original
* @param exit Exit condition, returns TRUE if there is no reason to try
*/
public RetryScalar(final Scalar<T> slr, final Func<Integer, Boolean> ext) {
this.scalar = slr;
this.exit = ext;
public RetryScalar(final Scalar<T> scalar,
final Func<Integer, Boolean> exit) {
this.origin = scalar;
this.func = exit;
}

@Override
public T value() throws Exception {
return new RetryFunc<>(
(Func<Boolean, T>) input -> this.scalar.value(),
this.exit
(Func<Boolean, T>) input -> this.origin.value(),
this.func
).apply(true);
}
}
6 changes: 3 additions & 3 deletions src/main/java/org/cactoos/scalar/StickyScalar.java
Original file line number Diff line number Diff line change
Expand Up @@ -51,11 +51,11 @@ public final class StickyScalar<T> implements Scalar<T> {

/**
* Ctor.
* @param src The Scalar to cache
* @param scalar The Scalar to cache
*/
public StickyScalar(final Scalar<T> src) {
public StickyScalar(final Scalar<T> scalar) {
this.func = new StickyFunc<>(
input -> src.value()
input -> scalar.value()
);
}

Expand Down
18 changes: 9 additions & 9 deletions src/main/java/org/cactoos/scalar/SyncScalar.java
Original file line number Diff line number Diff line change
Expand Up @@ -38,12 +38,12 @@ public final class SyncScalar<T> implements Scalar<T> {
/**
* The scalar to cache.
*/
private final Scalar<T> source;
private final Scalar<T> origin;

/**
* Sync lock.
*/
private final Object lck;
private final Object mutex;

/**
* Ctor.
Expand All @@ -55,18 +55,18 @@ public SyncScalar(final Scalar<T> src) {

/**
* Ctor.
* @param src The Scalar to cache
* @param lck Sync lock
* @param scalar The Scalar to cache
* @param lock Sync lock
*/
public SyncScalar(final Scalar<T> src, final Object lck) {
this.source = src;
this.lck = lck;
public SyncScalar(final Scalar<T> scalar, final Object lock) {
this.origin = scalar;
this.mutex = lock;
}

@Override
public T value() throws Exception {
synchronized (this.lck) {
return this.source.value();
synchronized (this.mutex) {
return this.origin.value();
}
}
}
Loading

0 comments on commit 7fab56e

Please sign in to comment.