Skip to content

Commit

Permalink
Add the method to convert catheter to stream.
Browse files Browse the repository at this point in the history
  • Loading branch information
cao-awa committed Sep 1, 2024
1 parent 4888796 commit b8d54ff
Show file tree
Hide file tree
Showing 7 changed files with 35 additions and 1 deletion.
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
kotlin.code.style=official
version_name=1.0.33
version_name=1.0.34
artifact_id=catheter
group_id=com.github.cao.awa
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,8 @@
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.*;
import java.util.stream.LongStream;
import java.util.stream.Stream;

public class BooleanCatheter {
private static final Random RANDOM = new Random();
Expand Down Expand Up @@ -1234,6 +1236,10 @@ public boolean[] dArray() {
return this.targets;
}

public Stream<Boolean> stream() {
return list().stream();
}

public List<Boolean> list() {
List<Boolean> list = new ArrayList<>();
for (boolean l : array()) {
Expand Down
7 changes: 7 additions & 0 deletions src/main/java/com/github/cao/awa/catheter/ByteCatheter.java
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,9 @@
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.*;
import java.util.stream.LongStream;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;

public class ByteCatheter {
private static final Random RANDOM = new Random();
Expand Down Expand Up @@ -1236,6 +1239,10 @@ public byte[] dArray() {
return this.targets;
}

public Stream<Byte> stream() {
return list().stream();
}

public List<Byte> list() {
List<Byte> list = new ArrayList<>();
for (byte l : array()) {
Expand Down
5 changes: 5 additions & 0 deletions src/main/java/com/github/cao/awa/catheter/Catheter.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.*;
import java.util.stream.LongStream;
import java.util.stream.Stream;

public class Catheter<T> {
private static final Random RANDOM = new Random();
Expand Down Expand Up @@ -1649,6 +1650,10 @@ public T[] dArray() {
return this.targets;
}

public Stream<T> stream() {
return Arrays.stream(array());
}

public List<T> list() {
return Arrays.asList(array());
}
Expand Down
6 changes: 6 additions & 0 deletions src/main/java/com/github/cao/awa/catheter/DoubleCatheter.java
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.*;
import java.util.stream.DoubleStream;
import java.util.stream.LongStream;

public class DoubleCatheter {
private static final Random RANDOM = new Random();
Expand Down Expand Up @@ -1233,6 +1235,10 @@ public double[] dArray() {
return this.targets;
}

public DoubleStream stream() {
return DoubleStream.of(array());
}

public List<Double> list() {
List<Double> list = new ArrayList<>();
for (double l : array()) {
Expand Down
6 changes: 6 additions & 0 deletions src/main/java/com/github/cao/awa/catheter/IntCatheter.java
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,8 @@
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.*;
import java.util.stream.IntStream;
import java.util.stream.LongStream;

public class IntCatheter {
private static final Random RANDOM = new Random();
Expand Down Expand Up @@ -1234,6 +1236,10 @@ public int[] dArray() {
return this.targets;
}

public IntStream stream() {
return IntStream.of(array());
}

public List<Integer> list() {
List<Integer> list = new ArrayList<>();
for (int l : array()) {
Expand Down
4 changes: 4 additions & 0 deletions src/main/java/com/github/cao/awa/catheter/LongCatheter.java
Original file line number Diff line number Diff line change
Expand Up @@ -1290,6 +1290,10 @@ public long[] dArray() {
return this.targets;
}

public LongStream stream() {
return LongStream.of(array());
}

public List<Long> list() {
List<Long> list = new ArrayList<>();
for (long l : array()) {
Expand Down

0 comments on commit b8d54ff

Please sign in to comment.