Class RxJavaDecoder

reactive/src/main/java/feign/reactive/RxJavaDecoder.java:26–44

import java.lang.reflect.Type;

public class RxJavaDecoder implements Decoder {

  private final Decoder delegate;

  public RxJavaDecoder(Decoder decoder) {
    this.delegate = decoder;
  }

  @Override
  public Object decode(Response response, Type type) throws IOException, FeignException {
    Class<?> rawType = Types.getRawType(type);
    if (rawType.isAssignableFrom(Flowable.class)) {
      Type lastType = Types.resolveLastTypeParameter(type, Flowable.class);
      return delegate.decode(response, lastType);
    }

    return delegate.decode(response, type);
  }
}