How to not repeat the same operations in RxJava?












1















I have a code like following:



authRepository.login(userName, password)
.doOnSubscribe(__ -> apiProgress.setValue(ApiProgress.start()))
.doFinally(() -> apiProgress.setValue(ApiProgress.stop()))
.subscribe(login -> loginData.setValue(login),
err -> apiError.setValue(ApiError.create(err)))


I need to repeat doOnSubscribe(..) and doFinally for all api calls.



Is there any way to achieve this thing ?










share|improve this question





























    1















    I have a code like following:



    authRepository.login(userName, password)
    .doOnSubscribe(__ -> apiProgress.setValue(ApiProgress.start()))
    .doFinally(() -> apiProgress.setValue(ApiProgress.stop()))
    .subscribe(login -> loginData.setValue(login),
    err -> apiError.setValue(ApiError.create(err)))


    I need to repeat doOnSubscribe(..) and doFinally for all api calls.



    Is there any way to achieve this thing ?










    share|improve this question



























      1












      1








      1








      I have a code like following:



      authRepository.login(userName, password)
      .doOnSubscribe(__ -> apiProgress.setValue(ApiProgress.start()))
      .doFinally(() -> apiProgress.setValue(ApiProgress.stop()))
      .subscribe(login -> loginData.setValue(login),
      err -> apiError.setValue(ApiError.create(err)))


      I need to repeat doOnSubscribe(..) and doFinally for all api calls.



      Is there any way to achieve this thing ?










      share|improve this question
















      I have a code like following:



      authRepository.login(userName, password)
      .doOnSubscribe(__ -> apiProgress.setValue(ApiProgress.start()))
      .doFinally(() -> apiProgress.setValue(ApiProgress.stop()))
      .subscribe(login -> loginData.setValue(login),
      err -> apiError.setValue(ApiError.create(err)))


      I need to repeat doOnSubscribe(..) and doFinally for all api calls.



      Is there any way to achieve this thing ?







      java android rx-java rx-android






      share|improve this question















      share|improve this question













      share|improve this question




      share|improve this question








      edited Nov 20 '18 at 9:10









      akarnokd

      49.8k9103151




      49.8k9103151










      asked Nov 20 '18 at 8:22









      Vatish SharmaVatish Sharma

      148




      148
























          1 Answer
          1






          active

          oldest

          votes


















          2














          Welcome to StackOverflow! https://stackoverflow.com/conduct



          You can create something like this using Transformer (http://reactivex.io/RxJava/javadoc/rx/Single.Transformer.html)



          static <T> SingleTransformer<T, T> subscribeAndFinalTransformer() {
          return new SingleTransformer<T, T>() {
          @Override
          public SingleSource<T> apply(Single<T> upstream) {
          return upstream.doOnSubscribe(disposable -> {
          // Your doOnSubscribe Block
          }).doFinally(() -> {
          // Your doFinally Block
          });
          }
          };
          }


          and above reusable Transformer can be attached for all the Single using compose method.



          authRepository.login(userName, password).compose(subscribeAndFinalTransformer())
          .subscribe()

          authRepository.anotherApi().compose(subscribeAndFinalTransformer()).subscribe()


          if you are using Observable or Completable, you should use equivalent Transformer instead SingleTransformer



          EDIT:



          Above approach is convenient if you want to reuse some actions for only certain calls.



          if you want to attach the actions to all of your API calls you can create Retrofit CallAdapter



          class RxStreamAdapter implements CallAdapter {

          private final Class rawType;
          private final CallAdapter<Object, Object> nextAdapter;
          private final Type returnType;

          RxStreamAdapter(Class rawType,
          Type returnType,
          CallAdapter nextAdapter) {
          this.rawType = rawType;
          this.returnType = returnType;
          this.nextAdapter = nextAdapter;
          }

          @Override
          public Type responseType() {
          return nextAdapter.responseType();
          }

          @Override
          public Object adapt(Call call) {
          if (rawType == Single.class) {
          return ((Single) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else if (returnType == Completable.class) {
          return ((Completable) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else {
          // Observable
          return ((Observable<Object>) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          }
          }

          @NotNull
          private Consumer<Disposable> getDoOnSubscribe() {
          return disposable -> {

          };
          }

          @NotNull
          private Action getDoFinally() {
          return () -> {

          };
          }
          }


          And then add it while creating Retrofit Object (Before RxJava2CallAdapterFactory)



          RetrofitApi retrofitApi = new Retrofit
          .Builder()
          .addCallAdapterFactory(new CallAdapter.Factory() {
          @Override
          public CallAdapter<?, ?> get(Type returnType, Annotation annotations, Retrofit retrofit) {
          CallAdapter<?, ?> nextAdapter = retrofit.nextCallAdapter(this, returnType, annotations);
          Class<?> rawType = getRawType(returnType);
          if (rawType == Single.class || rawType == Observable.class || rawType == Completable.class) {
          return new RxStreamAdapter(getRawType(returnType), returnType, nextAdapter);
          } else {
          return nextAdapter;
          }
          }
          })
          .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
          .build()


          You can also set hooks using RxJavaPlugins. But you cannot differentiate b/w normal stream and Retrofit stream.



          Hope it helps!






          share|improve this answer


























          • Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

            – Vatish Sharma
            Nov 20 '18 at 9:34











          • Btw, you provided the answer of asked question so I am accepting your solution :).

            – Vatish Sharma
            Nov 20 '18 at 10:19











          • @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

            – Suryavel TR
            Nov 20 '18 at 11:53











          • Great! Thanks, this is exactly what I want to achieve.

            – Vatish Sharma
            Nov 20 '18 at 12:05











          Your Answer






          StackExchange.ifUsing("editor", function () {
          StackExchange.using("externalEditor", function () {
          StackExchange.using("snippets", function () {
          StackExchange.snippets.init();
          });
          });
          }, "code-snippets");

          StackExchange.ready(function() {
          var channelOptions = {
          tags: "".split(" "),
          id: "1"
          };
          initTagRenderer("".split(" "), "".split(" "), channelOptions);

          StackExchange.using("externalEditor", function() {
          // Have to fire editor after snippets, if snippets enabled
          if (StackExchange.settings.snippets.snippetsEnabled) {
          StackExchange.using("snippets", function() {
          createEditor();
          });
          }
          else {
          createEditor();
          }
          });

          function createEditor() {
          StackExchange.prepareEditor({
          heartbeatType: 'answer',
          autoActivateHeartbeat: false,
          convertImagesToLinks: true,
          noModals: true,
          showLowRepImageUploadWarning: true,
          reputationToPostImages: 10,
          bindNavPrevention: true,
          postfix: "",
          imageUploader: {
          brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
          contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
          allowUrls: true
          },
          onDemand: true,
          discardSelector: ".discard-answer"
          ,immediatelyShowMarkdownHelp:true
          });


          }
          });














          draft saved

          draft discarded


















          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53388850%2fhow-to-not-repeat-the-same-operations-in-rxjava%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown

























          1 Answer
          1






          active

          oldest

          votes








          1 Answer
          1






          active

          oldest

          votes









          active

          oldest

          votes






          active

          oldest

          votes









          2














          Welcome to StackOverflow! https://stackoverflow.com/conduct



          You can create something like this using Transformer (http://reactivex.io/RxJava/javadoc/rx/Single.Transformer.html)



          static <T> SingleTransformer<T, T> subscribeAndFinalTransformer() {
          return new SingleTransformer<T, T>() {
          @Override
          public SingleSource<T> apply(Single<T> upstream) {
          return upstream.doOnSubscribe(disposable -> {
          // Your doOnSubscribe Block
          }).doFinally(() -> {
          // Your doFinally Block
          });
          }
          };
          }


          and above reusable Transformer can be attached for all the Single using compose method.



          authRepository.login(userName, password).compose(subscribeAndFinalTransformer())
          .subscribe()

          authRepository.anotherApi().compose(subscribeAndFinalTransformer()).subscribe()


          if you are using Observable or Completable, you should use equivalent Transformer instead SingleTransformer



          EDIT:



          Above approach is convenient if you want to reuse some actions for only certain calls.



          if you want to attach the actions to all of your API calls you can create Retrofit CallAdapter



          class RxStreamAdapter implements CallAdapter {

          private final Class rawType;
          private final CallAdapter<Object, Object> nextAdapter;
          private final Type returnType;

          RxStreamAdapter(Class rawType,
          Type returnType,
          CallAdapter nextAdapter) {
          this.rawType = rawType;
          this.returnType = returnType;
          this.nextAdapter = nextAdapter;
          }

          @Override
          public Type responseType() {
          return nextAdapter.responseType();
          }

          @Override
          public Object adapt(Call call) {
          if (rawType == Single.class) {
          return ((Single) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else if (returnType == Completable.class) {
          return ((Completable) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else {
          // Observable
          return ((Observable<Object>) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          }
          }

          @NotNull
          private Consumer<Disposable> getDoOnSubscribe() {
          return disposable -> {

          };
          }

          @NotNull
          private Action getDoFinally() {
          return () -> {

          };
          }
          }


          And then add it while creating Retrofit Object (Before RxJava2CallAdapterFactory)



          RetrofitApi retrofitApi = new Retrofit
          .Builder()
          .addCallAdapterFactory(new CallAdapter.Factory() {
          @Override
          public CallAdapter<?, ?> get(Type returnType, Annotation annotations, Retrofit retrofit) {
          CallAdapter<?, ?> nextAdapter = retrofit.nextCallAdapter(this, returnType, annotations);
          Class<?> rawType = getRawType(returnType);
          if (rawType == Single.class || rawType == Observable.class || rawType == Completable.class) {
          return new RxStreamAdapter(getRawType(returnType), returnType, nextAdapter);
          } else {
          return nextAdapter;
          }
          }
          })
          .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
          .build()


          You can also set hooks using RxJavaPlugins. But you cannot differentiate b/w normal stream and Retrofit stream.



          Hope it helps!






          share|improve this answer


























          • Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

            – Vatish Sharma
            Nov 20 '18 at 9:34











          • Btw, you provided the answer of asked question so I am accepting your solution :).

            – Vatish Sharma
            Nov 20 '18 at 10:19











          • @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

            – Suryavel TR
            Nov 20 '18 at 11:53











          • Great! Thanks, this is exactly what I want to achieve.

            – Vatish Sharma
            Nov 20 '18 at 12:05
















          2














          Welcome to StackOverflow! https://stackoverflow.com/conduct



          You can create something like this using Transformer (http://reactivex.io/RxJava/javadoc/rx/Single.Transformer.html)



          static <T> SingleTransformer<T, T> subscribeAndFinalTransformer() {
          return new SingleTransformer<T, T>() {
          @Override
          public SingleSource<T> apply(Single<T> upstream) {
          return upstream.doOnSubscribe(disposable -> {
          // Your doOnSubscribe Block
          }).doFinally(() -> {
          // Your doFinally Block
          });
          }
          };
          }


          and above reusable Transformer can be attached for all the Single using compose method.



          authRepository.login(userName, password).compose(subscribeAndFinalTransformer())
          .subscribe()

          authRepository.anotherApi().compose(subscribeAndFinalTransformer()).subscribe()


          if you are using Observable or Completable, you should use equivalent Transformer instead SingleTransformer



          EDIT:



          Above approach is convenient if you want to reuse some actions for only certain calls.



          if you want to attach the actions to all of your API calls you can create Retrofit CallAdapter



          class RxStreamAdapter implements CallAdapter {

          private final Class rawType;
          private final CallAdapter<Object, Object> nextAdapter;
          private final Type returnType;

          RxStreamAdapter(Class rawType,
          Type returnType,
          CallAdapter nextAdapter) {
          this.rawType = rawType;
          this.returnType = returnType;
          this.nextAdapter = nextAdapter;
          }

          @Override
          public Type responseType() {
          return nextAdapter.responseType();
          }

          @Override
          public Object adapt(Call call) {
          if (rawType == Single.class) {
          return ((Single) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else if (returnType == Completable.class) {
          return ((Completable) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else {
          // Observable
          return ((Observable<Object>) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          }
          }

          @NotNull
          private Consumer<Disposable> getDoOnSubscribe() {
          return disposable -> {

          };
          }

          @NotNull
          private Action getDoFinally() {
          return () -> {

          };
          }
          }


          And then add it while creating Retrofit Object (Before RxJava2CallAdapterFactory)



          RetrofitApi retrofitApi = new Retrofit
          .Builder()
          .addCallAdapterFactory(new CallAdapter.Factory() {
          @Override
          public CallAdapter<?, ?> get(Type returnType, Annotation annotations, Retrofit retrofit) {
          CallAdapter<?, ?> nextAdapter = retrofit.nextCallAdapter(this, returnType, annotations);
          Class<?> rawType = getRawType(returnType);
          if (rawType == Single.class || rawType == Observable.class || rawType == Completable.class) {
          return new RxStreamAdapter(getRawType(returnType), returnType, nextAdapter);
          } else {
          return nextAdapter;
          }
          }
          })
          .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
          .build()


          You can also set hooks using RxJavaPlugins. But you cannot differentiate b/w normal stream and Retrofit stream.



          Hope it helps!






          share|improve this answer


























          • Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

            – Vatish Sharma
            Nov 20 '18 at 9:34











          • Btw, you provided the answer of asked question so I am accepting your solution :).

            – Vatish Sharma
            Nov 20 '18 at 10:19











          • @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

            – Suryavel TR
            Nov 20 '18 at 11:53











          • Great! Thanks, this is exactly what I want to achieve.

            – Vatish Sharma
            Nov 20 '18 at 12:05














          2












          2








          2







          Welcome to StackOverflow! https://stackoverflow.com/conduct



          You can create something like this using Transformer (http://reactivex.io/RxJava/javadoc/rx/Single.Transformer.html)



          static <T> SingleTransformer<T, T> subscribeAndFinalTransformer() {
          return new SingleTransformer<T, T>() {
          @Override
          public SingleSource<T> apply(Single<T> upstream) {
          return upstream.doOnSubscribe(disposable -> {
          // Your doOnSubscribe Block
          }).doFinally(() -> {
          // Your doFinally Block
          });
          }
          };
          }


          and above reusable Transformer can be attached for all the Single using compose method.



          authRepository.login(userName, password).compose(subscribeAndFinalTransformer())
          .subscribe()

          authRepository.anotherApi().compose(subscribeAndFinalTransformer()).subscribe()


          if you are using Observable or Completable, you should use equivalent Transformer instead SingleTransformer



          EDIT:



          Above approach is convenient if you want to reuse some actions for only certain calls.



          if you want to attach the actions to all of your API calls you can create Retrofit CallAdapter



          class RxStreamAdapter implements CallAdapter {

          private final Class rawType;
          private final CallAdapter<Object, Object> nextAdapter;
          private final Type returnType;

          RxStreamAdapter(Class rawType,
          Type returnType,
          CallAdapter nextAdapter) {
          this.rawType = rawType;
          this.returnType = returnType;
          this.nextAdapter = nextAdapter;
          }

          @Override
          public Type responseType() {
          return nextAdapter.responseType();
          }

          @Override
          public Object adapt(Call call) {
          if (rawType == Single.class) {
          return ((Single) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else if (returnType == Completable.class) {
          return ((Completable) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else {
          // Observable
          return ((Observable<Object>) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          }
          }

          @NotNull
          private Consumer<Disposable> getDoOnSubscribe() {
          return disposable -> {

          };
          }

          @NotNull
          private Action getDoFinally() {
          return () -> {

          };
          }
          }


          And then add it while creating Retrofit Object (Before RxJava2CallAdapterFactory)



          RetrofitApi retrofitApi = new Retrofit
          .Builder()
          .addCallAdapterFactory(new CallAdapter.Factory() {
          @Override
          public CallAdapter<?, ?> get(Type returnType, Annotation annotations, Retrofit retrofit) {
          CallAdapter<?, ?> nextAdapter = retrofit.nextCallAdapter(this, returnType, annotations);
          Class<?> rawType = getRawType(returnType);
          if (rawType == Single.class || rawType == Observable.class || rawType == Completable.class) {
          return new RxStreamAdapter(getRawType(returnType), returnType, nextAdapter);
          } else {
          return nextAdapter;
          }
          }
          })
          .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
          .build()


          You can also set hooks using RxJavaPlugins. But you cannot differentiate b/w normal stream and Retrofit stream.



          Hope it helps!






          share|improve this answer















          Welcome to StackOverflow! https://stackoverflow.com/conduct



          You can create something like this using Transformer (http://reactivex.io/RxJava/javadoc/rx/Single.Transformer.html)



          static <T> SingleTransformer<T, T> subscribeAndFinalTransformer() {
          return new SingleTransformer<T, T>() {
          @Override
          public SingleSource<T> apply(Single<T> upstream) {
          return upstream.doOnSubscribe(disposable -> {
          // Your doOnSubscribe Block
          }).doFinally(() -> {
          // Your doFinally Block
          });
          }
          };
          }


          and above reusable Transformer can be attached for all the Single using compose method.



          authRepository.login(userName, password).compose(subscribeAndFinalTransformer())
          .subscribe()

          authRepository.anotherApi().compose(subscribeAndFinalTransformer()).subscribe()


          if you are using Observable or Completable, you should use equivalent Transformer instead SingleTransformer



          EDIT:



          Above approach is convenient if you want to reuse some actions for only certain calls.



          if you want to attach the actions to all of your API calls you can create Retrofit CallAdapter



          class RxStreamAdapter implements CallAdapter {

          private final Class rawType;
          private final CallAdapter<Object, Object> nextAdapter;
          private final Type returnType;

          RxStreamAdapter(Class rawType,
          Type returnType,
          CallAdapter nextAdapter) {
          this.rawType = rawType;
          this.returnType = returnType;
          this.nextAdapter = nextAdapter;
          }

          @Override
          public Type responseType() {
          return nextAdapter.responseType();
          }

          @Override
          public Object adapt(Call call) {
          if (rawType == Single.class) {
          return ((Single) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else if (returnType == Completable.class) {
          return ((Completable) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          } else {
          // Observable
          return ((Observable<Object>) nextAdapter.adapt(call))
          .doOnSubscribe(getDoOnSubscribe())
          .doFinally(getDoFinally());
          }
          }

          @NotNull
          private Consumer<Disposable> getDoOnSubscribe() {
          return disposable -> {

          };
          }

          @NotNull
          private Action getDoFinally() {
          return () -> {

          };
          }
          }


          And then add it while creating Retrofit Object (Before RxJava2CallAdapterFactory)



          RetrofitApi retrofitApi = new Retrofit
          .Builder()
          .addCallAdapterFactory(new CallAdapter.Factory() {
          @Override
          public CallAdapter<?, ?> get(Type returnType, Annotation annotations, Retrofit retrofit) {
          CallAdapter<?, ?> nextAdapter = retrofit.nextCallAdapter(this, returnType, annotations);
          Class<?> rawType = getRawType(returnType);
          if (rawType == Single.class || rawType == Observable.class || rawType == Completable.class) {
          return new RxStreamAdapter(getRawType(returnType), returnType, nextAdapter);
          } else {
          return nextAdapter;
          }
          }
          })
          .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
          .build()


          You can also set hooks using RxJavaPlugins. But you cannot differentiate b/w normal stream and Retrofit stream.



          Hope it helps!







          share|improve this answer














          share|improve this answer



          share|improve this answer








          edited Nov 20 '18 at 11:50

























          answered Nov 20 '18 at 9:01









          Suryavel TRSuryavel TR

          2,47311420




          2,47311420













          • Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

            – Vatish Sharma
            Nov 20 '18 at 9:34











          • Btw, you provided the answer of asked question so I am accepting your solution :).

            – Vatish Sharma
            Nov 20 '18 at 10:19











          • @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

            – Suryavel TR
            Nov 20 '18 at 11:53











          • Great! Thanks, this is exactly what I want to achieve.

            – Vatish Sharma
            Nov 20 '18 at 12:05



















          • Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

            – Vatish Sharma
            Nov 20 '18 at 9:34











          • Btw, you provided the answer of asked question so I am accepting your solution :).

            – Vatish Sharma
            Nov 20 '18 at 10:19











          • @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

            – Suryavel TR
            Nov 20 '18 at 11:53











          • Great! Thanks, this is exactly what I want to achieve.

            – Vatish Sharma
            Nov 20 '18 at 12:05

















          Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

          – Vatish Sharma
          Nov 20 '18 at 9:34





          Thanks for answering. It does solve the problem at some extent but now I need to call compose(subscribeAndFinalTransformer()) every time I will call an api. Is there any alternative ?

          – Vatish Sharma
          Nov 20 '18 at 9:34













          Btw, you provided the answer of asked question so I am accepting your solution :).

          – Vatish Sharma
          Nov 20 '18 at 10:19





          Btw, you provided the answer of asked question so I am accepting your solution :).

          – Vatish Sharma
          Nov 20 '18 at 10:19













          @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

          – Suryavel TR
          Nov 20 '18 at 11:53





          @VatishSharma I hope you are using retrofit. I have updated the answer. I will still go with compose() instead CallAdapter due to flexibility. Again there are some cases you had to go with Adapter approach like when other developers might forget to attach the actions that needed for every call. In that case it would be helpful. Cheers !

          – Suryavel TR
          Nov 20 '18 at 11:53













          Great! Thanks, this is exactly what I want to achieve.

          – Vatish Sharma
          Nov 20 '18 at 12:05





          Great! Thanks, this is exactly what I want to achieve.

          – Vatish Sharma
          Nov 20 '18 at 12:05




















          draft saved

          draft discarded




















































          Thanks for contributing an answer to Stack Overflow!


          • Please be sure to answer the question. Provide details and share your research!

          But avoid



          • Asking for help, clarification, or responding to other answers.

          • Making statements based on opinion; back them up with references or personal experience.


          To learn more, see our tips on writing great answers.




          draft saved


          draft discarded














          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53388850%2fhow-to-not-repeat-the-same-operations-in-rxjava%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown





















































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown

































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown







          這個網誌中的熱門文章

          Xamarin.form Move up view when keyboard appear

          Post-Redirect-Get with Spring WebFlux and Thymeleaf

          Anylogic : not able to use stopDelay()