session-android/src/org/thoughtcrime/securesms/net/CompositeRequestController.java

package org.thoughtcrime.securesms.net;

import androidx.annotation.NonNull;

import com.annimon.stream.Stream;

import java.util.ArrayList;
import java.util.List;

public class CompositeRequestController implements RequestController {

  private final List<RequestController> controllers = new ArrayList<>();
  private       boolean                 canceled    = false;

  public synchronized void addController(@NonNull RequestController controller) {
    if (canceled) {
      controller.cancel();
    } else {
      controllers.add(controller);
    }
  }

  @Override
  public synchronized void cancel() {
    canceled = true;
    Stream.of(controllers).forEach(RequestController::cancel);
  }

  public synchronized boolean isCanceled() {
    return canceled;
  }
}