Skip to content

Commit 7c6b2bb

Browse files
SimY4velo
authored andcommitted
Bump reactive dependencies. (#1105)
Make reactive contract work with the latest project reactor class hierarchy.
1 parent c1d0064 commit 7c6b2bb

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

reactive/pom.xml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,9 @@
2828

2929
<properties>
3030
<main.basedir>${project.basedir}/..</main.basedir>
31-
<reactor.version>3.1.8.RELEASE</reactor.version>
32-
<reactive.streams.version>1.0.2</reactive.streams.version>
33-
<reactivex.version>2.2.2</reactivex.version>
31+
<reactor.version>3.3.0.RELEASE</reactor.version>
32+
<reactive.streams.version>1.0.3</reactive.streams.version>
33+
<reactivex.version>2.2.14</reactivex.version>
3434
<mockito.version>1.9.5</mockito.version>
3535
</properties>
3636

reactive/src/main/java/feign/reactive/ReactiveDelegatingContract.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
import feign.Types;
1919
import java.lang.reflect.ParameterizedType;
2020
import java.lang.reflect.Type;
21-
import java.util.Arrays;
2221
import java.util.List;
2322
import java.util.stream.Stream;
2423
import org.reactivestreams.Publisher;
@@ -74,8 +73,7 @@ private boolean isReactive(Type type) {
7473
return false;
7574
}
7675
ParameterizedType parameterizedType = (ParameterizedType) type;
77-
Type raw = parameterizedType.getRawType();
78-
return Arrays.asList(((Class) raw).getInterfaces())
79-
.contains(Publisher.class);
76+
Class<?> raw = (Class<?>) parameterizedType.getRawType();
77+
return Publisher.class.isAssignableFrom(raw);
8078
}
8179
}

0 commit comments

Comments
 (0)