public MaybeUseCase(final UseCaseExecutor useCaseExecutor,
                    final PostExecutionThread postExecutionThread) {
    super(useCaseExecutor, postExecutionThread);
    schedulersTransformer = new MaybeTransformer<R, R>() {
        @Override
        public Maybe<R> apply(Maybe<R> single) {
            return single.subscribeOn(useCaseExecutor.getScheduler())
                    .observeOn(postExecutionThread.getScheduler());
        }
    };
}
 

/**
 * Maybe 切换到主线程
 */
public static <T> MaybeTransformer<T, T> maybeToMain() {
    return upstream -> upstream.subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread());
}
 

private MaybeTransformer<? super R, ? extends R> getSchedulersTransformer() {
    return schedulersTransformer;
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(Class<T> mappedType) {
  return new MaybeUnmarshaller<>(Buffer::getDelegate, mappedType);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(TypeReference<T> mappedTypeRef) {
  return new MaybeUnmarshaller<>(Buffer::getDelegate, mappedTypeRef);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(Class<T> mappedType, ObjectCodec mapper) {
  return new MaybeUnmarshaller<>(Buffer::getDelegate, mappedType, mapper);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper) {
  return new MaybeUnmarshaller<>(Buffer::getDelegate, mappedTypeRef, mapper);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(Class<T> mappedType) {
  return new MaybeUnmarshaller<>(java.util.function.Function.identity(), mappedType);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(TypeReference<T> mappedTypeRef) {
  return new MaybeUnmarshaller<>(java.util.function.Function.identity(), mappedTypeRef);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(Class<T> mappedType, ObjectCodec mapper) {
  return new MaybeUnmarshaller<>(java.util.function.Function.identity(), mappedType, mapper);
}
 

public static <T> MaybeTransformer<Buffer, T> unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper) {
  return new MaybeUnmarshaller<>(java.util.function.Function.identity(), mappedTypeRef, mapper);
}