Skip to content

Commit 5a7e108

Browse files
committed
reactor module: remove threads pool configuration fix #389
1 parent 2031ae0 commit 5a7e108

4 files changed

Lines changed: 0 additions & 18 deletions

File tree

jooby-reactor/src/main/java/org/jooby/reactor/Reactor.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,6 @@
3333

3434
import com.google.inject.Binder;
3535
import com.typesafe.config.Config;
36-
import com.typesafe.config.ConfigFactory;
3736

3837
import reactor.core.publisher.Flux;
3938
import reactor.core.publisher.Mono;
@@ -50,7 +49,6 @@
5049
* <ul>
5150
* <li>map route operator that converts {@link Flux} and {@link Mono} into {@link Deferred} API.
5251
* </li>
53-
* <li>set a default server thread pool with the number of available processors.</li>
5452
* </ul>
5553
*
5654
* <h2>usage</h2>
@@ -218,8 +216,4 @@ public void configure(final Env env, final Config conf, final Binder binder) {
218216
.map(reactor(flux, mono));
219217
}
220218

221-
@Override
222-
public Config config() {
223-
return ConfigFactory.parseResources(getClass(), "reactor.conf");
224-
}
225219
}

jooby-reactor/src/main/resources/org/jooby/reactor/reactor.conf

Lines changed: 0 additions & 4 deletions
This file was deleted.

jooby-reactor/src/test/java/org/jooby/reactor/ReactorTest.java

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919

2020
import com.google.inject.Binder;
2121
import com.typesafe.config.Config;
22-
import com.typesafe.config.ConfigFactory;
2322

2423
import reactor.core.publisher.Flux;
2524
import reactor.core.publisher.Mono;
@@ -155,10 +154,4 @@ public void monoMapperWithAdapter() throws Exception {
155154
});
156155
}
157156

158-
@Test
159-
public void config() throws Exception {
160-
assertEquals(ConfigFactory.parseResources(Reactor.class, "reactor.conf"),
161-
new Reactor().config());
162-
}
163-
164157
}

md/doc/reactor/reactor.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
## exports
1616

1717
* map route operator that converts ```Flux``` and ```Mono``` into [Deferred API]({{defdocs}}/Deferred.html).
18-
* set a default server thread pool with the number of available processors.
1918

2019
## usage
2120

0 commit comments

Comments
 (0)