Android中使用RxJava的switchMap处理重复点击网络请求的疑问

Great question! You’ve hit on a key detail about how switchMap works—and you’re absolutely correct: switchMap doesn’t cancel the actual server-side processing of the first request. Here’s why, and what you can do about it:

What switchMap Actually Does #

When a new click event comes in while the first network request is still running, switchMap will:

• Immediately unsubscribe from the Observable returned by sendNetworkRequestToServer(searchText) for the first request.
• Discard any future emissions from that first Observable, so your downstream subscriber (like UI update logic) will never see its result.

But crucially, this only affects the Observable chain on the client side. If the first request has already been sent to the server, the server will keep processing it unless you explicitly cancel the underlying network call.

Why This Happens #

Most network libraries tie Observables to an underlying request object (e.g., Retrofit's Call). When you unsubscribe from the Observable, whether via switchMap or manually, the library may or may not cancel the actual HTTP request:

• Retrofit + RxJava: By default, unsubscribing from the Observable returned by Retrofit will call Call.cancel(), which tells the client to stop listening for the response and may prompt the server to abort processing (depending on server configuration).
• Custom network implementations: If your sendNetworkRequestToServer method uses a custom setup that doesn’t link unsubscribe events to request cancellation, the server will finish processing the request even if the Observable is unsubscribed.

Fixes to Properly Cancel In-Flight Requests #

1. Use a Network Library That Supports Cancellation
   If you’re using Retrofit, you’re already covered. Ensure your API interface returns an Observable tied to a Retrofit Call:

   public interface SearchApi {
       @GET("/search")
       Observable<SearchResult> search(@Query("query") String query);
   }
   

   When switchMap unsubscribes from this Observable, Retrofit will cancel the HTTP request, and the server will likely stop processing it (depending on how your server handles canceled requests).

2. Explicitly Cancel Requests in Custom Implementations
   If you’re using a custom network setup, modify sendNetworkRequestToServer to tie the Observable’s unsubscribe event to canceling the request. For example, using Observable.create:

   private Observable<SearchResult> sendNetworkRequestToServer(String searchText) {
       return Observable.create(emitter -> {
           CustomRequest request = new CustomRequest(searchText);
           
           // Start the request
           request.execute(response -> {
               if (!emitter.isDisposed()) {
                   emitter.onNext(response);
                   emitter.onComplete();
               }
           });
           
           // Tie unsubscribe to request cancellation
           emitter.setCancellable(request::cancel);
       });
   }
   

   Now, when switchMap unsubscribes, request.cancel() will be called, stopping the network request (and ideally, server processing).

3. Filter Stale Results (If Cancellation Isn’t Possible)
   If you can’t cancel the server request (e.g., legacy APIs), you can still ensure stale results don’t reach your UI by tracking the latest query:

   AtomicReference<String> latestQuery = new AtomicReference<>();
   
   buttonClickObservable
       .map(e -> searchTextView.getText().toString())
       .doOnNext(latestQuery::set)
       .switchMap(searchText -> 
           sendNetworkRequestToServer(searchText)
               .filter(result -> result.getQuery().equals(latestQuery.get()))
       )
       .subscribe(result -> {
           // Only process results from the latest query
       });
   

Summary #

switchMap solves the problem of not showing stale results to the user by cutting off the old Observable’s downstream. To fully cancel the server-side request, you need to ensure your network Observable is set up to trigger request cancellation when unsubscribed.

内容的提问来源于stack exchange，提问作者user1409534