Skip to content

Commit

Permalink
Alternative internal builder process
Browse files Browse the repository at this point in the history
  • Loading branch information
velo committed Aug 21, 2023
1 parent 9981206 commit 540370d
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 11 deletions.
12 changes: 6 additions & 6 deletions reactive/src/main/java/feign/reactive/ReactorFeign.java
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,13 @@
package feign.reactive;

import feign.Feign;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;
import feign.InvocationHandlerFactory;
import feign.Target;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.util.Map;
import feign.InvocationHandlerFactory;
import feign.Target;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;

public class ReactorFeign extends ReactiveFeign {

Expand All @@ -41,9 +41,9 @@ public static class Builder extends ReactiveFeign.Builder {
}

@Override
public Feign build() {
public Feign internalBuild() {
super.invocationHandlerFactory(new ReactorInvocationHandlerFactory(scheduler));
return super.build();
return super.internalBuild();
}

@Override
Expand Down
10 changes: 5 additions & 5 deletions reactive/src/main/java/feign/reactive/RxJavaFeign.java
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,14 @@
*/
package feign.reactive;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.util.Map;
import feign.Feign;
import feign.InvocationHandlerFactory;
import feign.Target;
import io.reactivex.Scheduler;
import io.reactivex.schedulers.Schedulers;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.util.Map;

public class RxJavaFeign extends ReactiveFeign {

Expand All @@ -33,9 +33,9 @@ public static class Builder extends ReactiveFeign.Builder {
private Scheduler scheduler = Schedulers.trampoline();

@Override
public Feign build() {
public Feign internalBuild() {
super.invocationHandlerFactory(new RxJavaInvocationHandlerFactory(scheduler));
return super.build();
return super.internalBuild();
}

@Override
Expand Down

0 comments on commit 540370d

Please sign in to comment.