Skip to content

Commit c78c49a

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

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
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 & 3 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;
@@ -75,7 +74,7 @@ private boolean isReactive(Type type) {
7574
return false;
7675
}
7776
ParameterizedType parameterizedType = (ParameterizedType) type;
78-
Type raw = parameterizedType.getRawType();
79-
return Arrays.asList(((Class) raw).getInterfaces()).contains(Publisher.class);
77+
Class<?> raw = (Class<?>) parameterizedType.getRawType();
78+
return Publisher.class.isAssignableFrom(raw);
8079
}
8180
}

0 commit comments

Comments
 (0)