reactive

build.gradle

@@ -14,6 +14,8 @@ allprojects {
         set('MyBatisPlusVersion', '3.5.2')
         set('NettyVersion', '4.1.85.Final')
         set('RedissonVersion', '3.22.1')
+        set('ReactorVersion', '3.4.25')
+        set('Rxjava3Version', '3.1.8')
         set('XnioVersion', '3.8.6.Final')
         set('VueVersion', '2.6.11')
         set('VueResourceVersion', '1.5.1')

concept-reactive/build.gradle

@@ -0,0 +1,2 @@
+apply from: 'version.gradle'
+version ConceptReactiveVersion

concept-reactive/concept-reactive-core/build.gradle

@@ -0,0 +1,15 @@
+apply from: '../../allprojects.gradle'
+
+apply from: '../version.gradle'
+version ConceptReactiveVersion
+
+ext {
+    set('publishName', 'Reactive Core')
+    set('publishDescription', 'Reactive Core')
+}
+
+dependencies {
+
+}
+
+apply from: '../../publish.gradle'

concept-reactive/concept-reactive-core/src/main/java/com/github/linyuzai/reactive/core/concept/ReactiveCollection.java

@@ -0,0 +1,8 @@
+package com.github.linyuzai.reactive.core.concept;
+
+public interface ReactiveCollection {
+
+    interface Factory {
+
+    }
+}

concept-reactive/concept-reactive-core/src/main/java/com/github/linyuzai/reactive/core/concept/ReactiveConcept.java

@@ -0,0 +1,8 @@
+package com.github.linyuzai.reactive.core.concept;
+
+public interface ReactiveConcept {
+
+    ReactiveObject.Factory objectFactory();
+
+    ReactiveCollection.Factory collectionFactory();
+}

concept-reactive/concept-reactive-core/src/main/java/com/github/linyuzai/reactive/core/concept/ReactiveObject.java

@@ -0,0 +1,8 @@
+package com.github.linyuzai.reactive.core.concept;
+
+public interface ReactiveObject {
+
+    interface Factory {
+
+    }
+}

concept-reactive/concept-reactive-reactor/build.gradle

@@ -0,0 +1,16 @@
+apply from: '../../allprojects.gradle'
+
+apply from: '../version.gradle'
+version ConceptReactiveVersion
+
+ext {
+    set('publishName', 'Reactive Reactor')
+    set('publishDescription', 'Reactive 4 Reactor')
+}
+
+dependencies {
+    compileOnly "io.projectreactor:reactor-core:${ReactorVersion}"
+    compileOnly project(':concept-reactive:concept-reactive-core')
+}
+
+apply from: '../../publish.gradle'

concept-reactive/concept-reactive-reactor/src/main/java/com/github/linyuzai/reactive/reactor/concept/ReactorCollection.java

@@ -0,0 +1,6 @@
+package com.github.linyuzai.reactive.reactor.concept;
+
+import com.github.linyuzai.reactive.core.concept.ReactiveCollection;
+
+public class ReactorCollection implements ReactiveCollection {
+}

concept-reactive/concept-reactive-reactor/src/main/java/com/github/linyuzai/reactive/reactor/concept/ReactorConcept.java

@@ -0,0 +1,19 @@
+package com.github.linyuzai.reactive.reactor.concept;
+
+import com.github.linyuzai.reactive.core.concept.ReactiveCollection;
+import com.github.linyuzai.reactive.core.concept.ReactiveConcept;
+import com.github.linyuzai.reactive.core.concept.ReactiveObject;
+import reactor.core.publisher.Mono;
+
+public class ReactorConcept implements ReactiveConcept {
+
+    @Override
+    public ReactiveObject.Factory objectFactory() {
+        return new ReactorObject.MonoFactory();
+    }
+
+    @Override
+    public ReactiveCollection.Factory collectionFactory() {
+        return null;
+    }
+}

concept-reactive/concept-reactive-reactor/src/main/java/com/github/linyuzai/reactive/reactor/concept/ReactorObject.java

@@ -0,0 +1,13 @@
+package com.github.linyuzai.reactive.reactor.concept;
+
+import com.github.linyuzai.reactive.core.concept.ReactiveObject;
+import reactor.core.publisher.Mono;
+
+public class ReactorObject<T> implements ReactiveObject {
+
+    private Mono<T> mono;
+
+    public static class MonoFactory implements Factory {
+
+    }
+}

concept-reactive/concept-reactive-rxjava3/build.gradle

@@ -0,0 +1,16 @@
+apply from: '../../allprojects.gradle'
+
+apply from: '../version.gradle'
+version ConceptReactiveVersion
+
+ext {
+    set('publishName', 'Reactive Rxjava3')
+    set('publishDescription', 'Reactive 4 Rxjava3')
+}
+
+dependencies {
+    compileOnly "io.reactivex.rxjava3:${Rxjava3Version}"
+    compileOnly project(':concept-reactive:concept-reactive-core')
+}
+
+apply from: '../../publish.gradle'

concept-reactive/concept-reactive-rxjava3/src/main/java/com/github/linyuzai/reactive/rxjava3/concept/RxJava3Collection.java

@@ -0,0 +1,8 @@
+package com.github.linyuzai.reactive.rxjava3.concept;
+
+import com.github.linyuzai.reactive.core.concept.ReactiveCollection;
+
+public class RxJava3Collection implements ReactiveCollection {
+
+
+}

concept-reactive/concept-reactive-rxjava3/src/main/java/com/github/linyuzai/reactive/rxjava3/concept/RxJava3Concept.java

@@ -0,0 +1,6 @@
+package com.github.linyuzai.reactive.rxjava3.concept;
+
+import com.github.linyuzai.reactive.core.concept.ReactiveConcept;
+
+public class RxJava3Concept implements ReactiveConcept {
+}

concept-reactive/concept-reactive-rxjava3/src/main/java/com/github/linyuzai/reactive/rxjava3/concept/RxJava3Object.java

@@ -0,0 +1,6 @@
+package com.github.linyuzai.reactive.rxjava3.concept;
+
+import com.github.linyuzai.reactive.core.concept.ReactiveObject;
+
+public class RxJava3Object implements ReactiveObject {
+}

concept-reactive/version.gradle

@@ -0,0 +1 @@
+ext.'ConceptReactiveVersion' = '1.0.0'

settings.gradle

@@ -38,6 +38,10 @@ include 'concept-plugin:concept-plugin-jar'
 include 'concept-plugin:concept-plugin-spring-boot-starter'
 include 'concept-properties-refresh'
 include 'concept-properties-refresh:concept-properties-refresh-core'
+include 'concept-reactive'
+include 'concept-reactive:concept-reactive-core'
+include 'concept-reactive:concept-reactive-reactor'
+include 'concept-reactive:concept-reactive-rxjava3'
 include 'concept-router'
 include 'concept-router:concept-router-core'
 include 'concept-router:concept-router-loadbalancer'