Merge pull request #5 from lokic/dev/0.2.1

Dev/0.2.1

Author: lokic

README.md

@@ -49,7 +49,7 @@
 - Lazy：带缓存功能的 Supplier
 
   - Supplier 每一次执行 Supplier.get() 都会执行一次 Supplier.get() 内的业务逻辑。 如果在一些Supplier.get() 比较耗时的场景，且多次执行 Supplier.get()
-    结果相同的情况下， 我们没有必要多次执行，只需要把执行第一次的结果保存下来，之后多次调用直接返回即可，Lazy 就是这个目的设计出来的。
+    ，结果相同的情况下， 我们没有必要多次执行，只需要把执行第一次的结果保存下来，之后多次调用直接返回即可，Lazy 就是这个目的设计出来的。
 
 - [Property](https://github.com/lokic/java-plus/tree/master/src/main/java/com/github/lokic/javaplus/property)
   ：在定义枚举类之后，经常需要基于枚举类的某个字段作为key来查询枚举，抽象出这个模块来实现key到枚举的映射和转换逻辑，[示例](https://github.com/lokic/java-plus/tree/master/src/test/java/com/github/lokic/javaplus/property)
@@ -69,3 +69,18 @@
   - Collectors.Reversed：倒序相关
   - Collectors.Distinct：去重相关
 
+- [Join](https://github.com/lokic/java-plus/tree/master/src/main/java/com/github/lokic/javaplus/join/Join.java)
+  ：一种类似SQL中join的操作，可以把内存中的Stream流像操作数据库中的表一样进行各种join
+
+   ```java
+   Stream<Integer> streamA = Stream.of(1, 2, 3, 4);
+   Stream<String> streamB = Stream.of("1", "2", "3");
+   
+   Join.stream(streamA)
+     .leftOuterJoin(streamB, Join.on(a -> String.valueOf(a), b -> b)
+     .stream()   // 转成Stream之后是一个多元组的流，可以结合TupleFunctional进行很多便利的操作
+     .map(...)
+   ```
+
+  
+

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.github.lokic</groupId>
     <artifactId>java-plus</artifactId>
-    <version>0.2.0</version>
+    <version>0.2.1-SNAPSHOT</version>
     <name>java-plus</name>
     <description>Provide some useful extensions on the basis of java8 to make java more usable.</description>
     <url>https://github.com/lokic/java-plus</url>

src/main/java/com/github/lokic/javaplus/functional/function/Function7.java

@@ -0,0 +1,37 @@
+package com.github.lokic.javaplus.functional.function;
+
+import java.util.function.Function;
+
+@FunctionalInterface
+public interface Function7<T1, T2, T3, T4, T5, T6, T7, R> {
+    R apply(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7);
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $1(Function<T1, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t1);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $2(Function<T2, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t2);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $3(Function<T3, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t3);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $4(Function<T4, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t4);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $5(Function<T5, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t5);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $6(Function<T6, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t6);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, R> Function7<T1, T2, T3, T4, T5, T6, T7, R> $7(Function<T7, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7) -> function.apply(t7);
+    }
+
+}

src/main/java/com/github/lokic/javaplus/functional/function/Function8.java

@@ -0,0 +1,42 @@
+package com.github.lokic.javaplus.functional.function;
+
+import java.util.function.Function;
+
+@FunctionalInterface
+public interface Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> {
+    R apply(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8);
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $1(Function<T1, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t1);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $2(Function<T2, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t2);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $3(Function<T3, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t3);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $4(Function<T4, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t4);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $5(Function<T5, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t5);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $6(Function<T6, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t6);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $7(Function<T7, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t7);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, R> Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> $8(Function<T8, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8) -> function.apply(t8);
+    }
+
+
+}

src/main/java/com/github/lokic/javaplus/functional/function/Function9.java

@@ -0,0 +1,45 @@
+package com.github.lokic.javaplus.functional.function;
+
+import java.util.function.Function;
+
+@FunctionalInterface
+public interface Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> {
+    R apply(T1 t1, T2 t2, T3 t3, T4 t4, T5 t5, T6 t6, T7 t7, T8 t8, T9 t9);
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $1(Function<T1, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t1);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $2(Function<T2, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t2);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $3(Function<T3, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t3);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $4(Function<T4, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t4);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $5(Function<T5, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t5);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $6(Function<T6, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t6);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $7(Function<T7, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t7);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $8(Function<T8, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t8);
+    }
+
+    static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> $9(Function<T9, R> function) {
+        return (t1, t2, t3, t4, t5, t6, t7, t8, t9) -> function.apply(t9);
+    }
+
+}

src/main/java/com/github/lokic/javaplus/functional/predicate/Predicate4.java

@@ -0,0 +1,25 @@
+package com.github.lokic.javaplus.functional.predicate;
+
+
+import java.util.function.Predicate;
+
+@FunctionalInterface
+public interface Predicate4<T1, T2, T3, T4> {
+    boolean test(T1 t1, T2 t2, T3 t3, T4 t4);
+
+    static <T1, T2, T3, T4> Predicate4<T1, T2, T3, T4> $1(Predicate<T1> predicate) {
+        return (t1, t2, t3, t4) -> predicate.test(t1);
+    }
+
+    static <T1, T2, T3, T4> Predicate4<T1, T2, T3, T4> $2(Predicate<T2> predicate) {
+        return (t1, t2, t3, t4) -> predicate.test(t2);
+    }
+
+    static <T1, T2, T3, T4> Predicate4<T1, T2, T3, T4> $3(Predicate<T3> predicate) {
+        return (t1, t2, t3, t4) -> predicate.test(t3);
+    }
+
+    static <T1, T2, T3, T4> Predicate4<T1, T2, T3, T4> $4(Predicate<T4> predicate) {
+        return (t1, t2, t3, t4) -> predicate.test(t4);
+    }
+}

src/main/java/com/github/lokic/javaplus/functional/sneakythrows/SneakyThrowsConsumer2.java

@@ -0,0 +1,16 @@
+package com.github.lokic.javaplus.functional.sneakythrows;
+
+import com.github.lokic.javaplus.functional.consumer.Consumer2;
+import com.github.lokic.javaplus.functional.throwable.ThrowsConsumer2;
+import lombok.SneakyThrows;
+
+@FunctionalInterface
+public interface SneakyThrowsConsumer2<T1, T2> extends Consumer2<T1, T2>, ThrowsConsumer2<T1, T2> {
+
+    @SneakyThrows
+    @Override
+    default void accept(T1 t1, T2 t2) {
+        throwableAccept(t1, t2);
+    }
+
+}

src/main/java/com/github/lokic/javaplus/functional/sneakythrows/SneakyThrowsConsumer3.java

@@ -0,0 +1,16 @@
+package com.github.lokic.javaplus.functional.sneakythrows;
+
+import com.github.lokic.javaplus.functional.consumer.Consumer3;
+import com.github.lokic.javaplus.functional.throwable.ThrowsConsumer3;
+import lombok.SneakyThrows;
+
+@FunctionalInterface
+public interface SneakyThrowsConsumer3<T1, T2, T3> extends Consumer3<T1, T2, T3>, ThrowsConsumer3<T1, T2, T3> {
+
+    @SneakyThrows
+    @Override
+    default void accept(T1 t1, T2 t2, T3 t3) {
+        throwableAccept(t1, t2, t3);
+    }
+
+}

src/main/java/com/github/lokic/javaplus/functional/sneakythrows/SneakyThrowsConsumer4.java

@@ -0,0 +1,16 @@
+package com.github.lokic.javaplus.functional.sneakythrows;
+
+import com.github.lokic.javaplus.functional.consumer.Consumer4;
+import com.github.lokic.javaplus.functional.throwable.ThrowsConsumer4;
+import lombok.SneakyThrows;
+
+@FunctionalInterface
+public interface SneakyThrowsConsumer4<T1, T2, T3, T4> extends Consumer4<T1, T2, T3, T4>, ThrowsConsumer4<T1, T2, T3, T4> {
+
+    @SneakyThrows
+    @Override
+    default void accept(T1 t1, T2 t2, T3 t3, T4 t4) {
+        throwableAccept(t1, t2, t3, t4);
+    }
+
+}

src/main/java/com/github/lokic/javaplus/functional/sneakythrows/SneakyThrowsFunction4.java

@@ -0,0 +1,16 @@
+package com.github.lokic.javaplus.functional.sneakythrows;
+
+import com.github.lokic.javaplus.functional.throwable.ThrowsFunction4;
+import com.github.lokic.javaplus.functional.tuple.TupleFunction4;
+import lombok.SneakyThrows;
+
+@FunctionalInterface
+public interface SneakyThrowsFunction4<T1, T2, T3, T4, R> extends TupleFunction4<T1, T2, T3, T4, R>, ThrowsFunction4<T1, T2, T3, T4, R> {
+
+    @SneakyThrows
+    @Override
+    default R apply(T1 t1, T2 t2, T3 t3, T4 t4) {
+        return throwableApply(t1, t2, t3, t4);
+    }
+
+}