如何在Kotlin中实现Java step Builder模式

我正在将一个100%Java Android应用程序改写为100%Kotlin。 不过,我一直在尝试实现我的Java step构建器。

我使用Java step Builder,因为它们迫使代码用户在能够执行相关RxJava进程之前提供所有必需的数据和/或函数。

这些RxJava过程非常复杂,我希望尽可能简化它们的初始化和执行。

Java Step Builder的使用允许开发人员编写以下代码:-

Sequence.builder()
    .stepOne(one)
    .stepTwo(two)
    .stepThree(three)
    .build()
    .execute();

我想要的是这种方法的Kotlin版本。 我最初的想法是,科特林将支持建设者和Step建设者。

我并不“珍视”在Kotlin中雇佣建设者,Kotlin解决方案必须迫使使用我的代码的开发人员在能够执行相关的“已执行”代码之前提供所有必需的数据和/或函数。

通过对Kotlin的调查,我发现了内部DSL,它们本身听起来既有有趣的话题,也有可能解决这个特定问题。

我有很多Step构建器要实现,其中没有一个有超过6个参数。不过,我确实喜欢尝试保持固体不超过三个参数。

此外,如果有什么不同,那么传递的一些参数是RxJava操作和使用者。默认值在这里不相关,因为没有一个参数具有可行的默认值。

使现代化

我的Java step构建器都是这样的:-

public class ExampleSequence extends Sequence {

    private static final String TAG = "ExampleSequence";

    private final Action onComplete;
    private final Consumer<? super Throwable> onError;

    /**
     * @param builder
     */
    private ExampleSequence(final Builder builder) {
        super(builder.getDoLoginRefreshFail());
        this.onError = builder.getOnError();
        this.onComplete = builder.getOnComplete();
    }

    /**
     *
     */
    public static OnCompleteAction builder() {
        return new Builder();
    }

    public interface OnCompleteAction {
        onErrorAction onComplete(@NonNull final Action onComplete);
    }

    public interface onErrorAction {
        DoLoginRefreshFail onError(@NonNull final Consumer<? super Throwable> onError);
    }

    public interface DoLoginRefreshFail {
        Build doLoginRefreshFail(@NonNull final Action doLoginRefreshFail);
    }

    public interface Build {
        ExampleSequence build();
    }

    @SuppressLint("CheckResult")
    public void execute() {
        final AtomicInteger retryCounter = new AtomicInteger(0);

        final Observable<Response<GraphqlQueryResponse>> feedArticles = getPageAndNextInboxArticles(offset, limit)
                .onErrorResumeNext(manufactureResumeNext())
                .subscribeOn(Schedulers.io());

        final Observable<Response<GraphqlQueryResponse>> readingListArticles = getPageAndReadingListArticles(readingListoffset, limit)
                .onErrorResumeNext(manufactureResumeNext())
                .subscribeOn(Schedulers.io());

        login()
                .flatMap(...)
                .ignoreElement()
                .andThen(...)
                .andThen(...)
                .ignoreElements()
                .andThen(...)
                .flattenAsObservable(x -> x)
                .flatMapCompletable(...)
                .retryWhen(errors -> errors.flatMap(e -> constructRetryHandler(retryCounter, e)))
                .doOnComplete(onComplete)
                .doOnError(onError)
                .doAfterTerminate(doAfterTerminate())
                .doOnSubscribe(compositeDisposable::add)
                .blockingAwait();
    }

    /**********************************************************************************
     *
     * BUILDER
     *
     */
    public static class Builder implements OnCompleteAction, onErrorAction, DoLoginRefreshFail, Build {

        private Action onComplete;
        private Consumer<? super Throwable> onError;
        private Action doLoginRefreshFail;

        /***********************************************************************
         *
         */
        @Override
        public ExampleSequence build() {
            return new ExampleSequence(this);
        }

        @Override
        public onErrorAction onComplete(@NonNull final Action onComplete) {
            this.onComplete = onComplete;
            return this;
        }

        @Override
        public DoLoginRefreshFail onError(@NonNull final Consumer<? super Throwable> onError) {
            this.onError = onError;
            return this;
        }


        @Override
        public Build doLoginRefreshFail(@NonNull final Action doLoginRefreshFail) {
            this.doLoginRefreshFail = doLoginRefreshFail;
            return this;
        }

        /**
         * @return the onError
         */
        Consumer<? super Throwable> getOnError() {
            return onError;
        }

        /**
         * @return the onComplete
         */
        Action getOnComplete() {
            return onComplete;
        }

        Action getDoLoginRefreshFail() {
            return doLoginRefreshFail;
        }
    }
}