Class ReactorDecoder

reactive/src/main/java/feign/reactive/ReactorDecoder.java:28–51

import reactor.core.publisher.Mono;

public class ReactorDecoder implements Decoder {

  private final Decoder delegate;

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

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

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