Skip to content

Commit 40684b4

Browse files
authored
feat: use Java 17 as a baseline (#238)
1 parent 5272c0d commit 40684b4

File tree

4 files changed

+10
-26
lines changed

4 files changed

+10
-26
lines changed

.github/workflows/build-main.yml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ jobs:
1212
strategy:
1313
matrix:
1414
java: [
15-
{ 'version': '11', 'opts': '' },
1615
{ 'version': '17', 'opts': '' },
1716
{ 'version': '21', 'opts': '' }
1817
]

.github/workflows/build-pull-request.yml

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,7 @@ jobs:
88
strategy:
99
matrix:
1010
java: [
11-
{ 'version': '11', 'opts': '' },
1211
{ 'version': '17', 'opts': '' },
13-
{ 'version': '21', 'opts': '' },
1412
{ 'version': '23', 'opts': '' }
1513
]
1614
name: Build with Java ${{ matrix.java.version }} (OpenJDK)
@@ -36,7 +34,7 @@ jobs:
3634
name: Set up JDK 11
3735
with:
3836
distribution: temurin
39-
java-version: 11
37+
java-version: 17
4038
cache: maven
4139
- name: Compatibility Check
4240
run: ./mvnw -s .github/maven-ci-settings.xml -B install revapi:check@check-compatibility -DskipTests -fae

mutiny-zero/src/main/java/mutiny/zero/internal/TubePublisher.java

Lines changed: 8 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -25,27 +25,14 @@ public TubePublisher(TubeConfiguration configuration, Consumer<Tube<T>> tubeCons
2525
@Override
2626
public void subscribe(Flow.Subscriber<? super T> subscriber) {
2727
requireNonNull(subscriber, "The subscriber cannot be null");
28-
TubeBase<T> tube = null;
29-
switch (backpressureStrategy) {
30-
case BUFFER:
31-
tube = new BufferingTube<>(subscriber, bufferSize);
32-
break;
33-
case UNBOUNDED_BUFFER:
34-
tube = new UnbounbedBufferingTube<>(subscriber);
35-
break;
36-
case DROP:
37-
tube = new DroppingTube<>(subscriber);
38-
break;
39-
case ERROR:
40-
tube = new ErroringTube<>(subscriber);
41-
break;
42-
case IGNORE:
43-
tube = new IgnoringTube<>(subscriber);
44-
break;
45-
case LATEST:
46-
tube = new LatestTube<>(subscriber, bufferSize);
47-
break;
48-
}
28+
TubeBase<T> tube = switch (backpressureStrategy) {
29+
case BUFFER -> new BufferingTube<>(subscriber, bufferSize);
30+
case UNBOUNDED_BUFFER -> new UnbounbedBufferingTube<>(subscriber);
31+
case DROP -> new DroppingTube<>(subscriber);
32+
case ERROR -> new ErroringTube<>(subscriber);
33+
case IGNORE -> new IgnoringTube<>(subscriber);
34+
case LATEST -> new LatestTube<>(subscriber, bufferSize);
35+
};
4936
subscriber.onSubscribe(tube);
5037
tubeConsumer.accept(tube);
5138
}

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@
7777
<revapi-reporter-json.version>0.5.0</revapi-reporter-json.version>
7878
<revapi-reporter-text.version>0.15.0</revapi-reporter-text.version>
7979

80-
<maven.compiler.release>11</maven.compiler.release>
80+
<maven.compiler.release>17</maven.compiler.release>
8181
</properties>
8282

8383
<dependencyManagement>

0 commit comments

Comments
 (0)