private boolean isReactive ( Type type ) { if ( ! ParameterizedType . class . isAssignableFrom ( type . getClass ( ) ) ) { return false ; } ParameterizedType parameterizedType = ( ParameterizedType ) type ; Type raw = parameterizedType . getRawType ( ) ; return Arrays . asList ( ( ( Class ) raw ) . getInterfaces ( ) ) . contains ( Publisher . class ) ; }
Ensure that the type provided implements a Reactive Streams Publisher .