content: /**
   * Copyright (c) 2016-present, RxJava Contributors.
   *
   * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in
   * compliance with the License. You may obtain a copy of the License at
   *
   * http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software distributed under the License is
   * distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See
   * the License for the specific language governing permissions and limitations under the License.
   */
  
  package io.reactivex.common.internal.disposables;
  
  import static org.junit.Assert.*;
  
  import java.util.*;
  
  import org.junit.Test;
  
  import io.reactivex.common.*;
  import io.reactivex.common.exceptions.*;
  
  public class ListCompositeDisposableTest {
  
      @Test
      public void constructorAndAddVarargs() {
          Disposable d1 = Disposables.empty();
          Disposable d2 = Disposables.empty();
  
          ListCompositeDisposable lcd = new ListCompositeDisposable(d1, d2);
  
          lcd.clear();
  
          assertFalse(lcd.isDisposed());
  
          assertTrue(d1.isDisposed());
          assertTrue(d2.isDisposed());
  
          d1 = Disposables.empty();
          d2 = Disposables.empty();
  
          lcd.addAll(d1, d2);
  
          lcd.dispose();
  
          assertTrue(lcd.isDisposed());
          assertTrue(d1.isDisposed());
          assertTrue(d2.isDisposed());
      }
  
      @Test
      public void constructorIterable() {
          Disposable d1 = Disposables.empty();
          Disposable d2 = Disposables.empty();
  
          ListCompositeDisposable lcd = new ListCompositeDisposable(Arrays.asList(d1, d2));
  
          lcd.clear();
  
          assertFalse(lcd.isDisposed());
  
          assertTrue(d1.isDisposed());
          assertTrue(d2.isDisposed());
  
          d1 = Disposables.empty();
          d2 = Disposables.empty();
  
          lcd.add(d1);
          lcd.addAll(d2);
  
          lcd.dispose();
  
          assertTrue(lcd.isDisposed());
          assertTrue(d1.isDisposed());
          assertTrue(d2.isDisposed());
      }
  
      @Test
      public void empty() {
          ListCompositeDisposable lcd = new ListCompositeDisposable();
  
          assertFalse(lcd.isDisposed());
  
          lcd.clear();
  
          assertFalse(lcd.isDisposed());
  
          lcd.dispose();
  
          lcd.dispose();
  
          lcd.clear();
  
          assertTrue(lcd.isDisposed());
      }
  
      @Test
      public void afterDispose() {
          ListCompositeDisposable lcd = new ListCompositeDisposable();
          lcd.dispose();
  
          Disposable d = Disposables.empty();
          assertFalse(lcd.add(d));
          assertTrue(d.isDisposed());
  
          d = Disposables.empty();
          assertFalse(lcd.addAll(d));
          assertTrue(d.isDisposed());
      }
  
      @Test
      public void disposeThrows() {
          Disposable d = new Disposable() {
  
              @Override
              public void dispose() {
                  throw new TestException();
              }
  
              @Override
              public boolean isDisposed() {
                  return false;
              }
  
          };
  
          ListCompositeDisposable lcd = new ListCompositeDisposable(d, d);
  
          try {
              lcd.dispose();
              fail("Should have thrown!");
          } catch (CompositeException ex) {
              List<Throwable> list = ex.getExceptions();
              TestCommonHelper.assertError(list, 0, TestException.class);
              TestCommonHelper.assertError(list, 1, TestException.class);
          }
  
          lcd = new ListCompositeDisposable(d);
  
          try {
              lcd.dispose();
              fail("Should have thrown!");
          } catch (TestException  ex) {
              // expected
          }
      }
  
      @Test
      public void remove() {
          ListCompositeDisposable lcd = new ListCompositeDisposable();
          Disposable d = Disposables.empty();
  
          lcd.add(d);
  
          assertTrue(lcd.delete(d));
  
          assertFalse(d.isDisposed());
  
          lcd.add(d);
  
          assertTrue(lcd.remove(d));
  
          assertTrue(d.isDisposed());
  
          assertFalse(lcd.remove(d));
  
          assertFalse(lcd.delete(d));
  
          lcd = new ListCompositeDisposable();
  
          assertFalse(lcd.remove(d));
  
          assertFalse(lcd.delete(d));
      }
  
      @Test
      public void disposeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.dispose();
                  }
              };
  
              TestCommonHelper.race(run, run, Schedulers.io());
          }
      }
  
      @Test
      public void addRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.add(Disposables.empty());
                  }
              };
  
              TestCommonHelper.race(run, run, Schedulers.io());
          }
      }
  
      @Test
      public void addAllRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.addAll(Disposables.empty());
                  }
              };
  
              TestCommonHelper.race(run, run, Schedulers.io());
          }
      }
  
      @Test
      public void removeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              final Disposable d1 = Disposables.empty();
  
              cd.add(d1);
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.remove(d1);
                  }
              };
  
              TestCommonHelper.race(run, run, Schedulers.io());
          }
      }
  
      @Test
      public void deleteRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              final Disposable d1 = Disposables.empty();
  
              cd.add(d1);
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.delete(d1);
                  }
              };
  
              TestCommonHelper.race(run, run, Schedulers.io());
          }
      }
  
      @Test
      public void clearRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              final Disposable d1 = Disposables.empty();
  
              cd.add(d1);
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.clear();
                  }
              };
  
              TestCommonHelper.race(run, run, Schedulers.io());
          }
      }
  
      @Test
      public void addDisposeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.dispose();
                  }
              };
  
              Runnable run2 = new Runnable() {
                  @Override
                  public void run() {
                      cd.add(Disposables.empty());
                  }
              };
  
              TestCommonHelper.race(run, run2, Schedulers.io());
          }
      }
  
      @Test
      public void addAllDisposeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.dispose();
                  }
              };
  
              Runnable run2 = new Runnable() {
                  @Override
                  public void run() {
                      cd.addAll(Disposables.empty());
                  }
              };
  
              TestCommonHelper.race(run, run2, Schedulers.io());
          }
      }
  
      @Test
      public void removeDisposeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              final Disposable d1 = Disposables.empty();
  
              cd.add(d1);
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.dispose();
                  }
              };
  
              Runnable run2 = new Runnable() {
                  @Override
                  public void run() {
                      cd.remove(d1);
                  }
              };
  
              TestCommonHelper.race(run, run2, Schedulers.io());
          }
      }
  
      @Test
      public void deleteDisposeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              final Disposable d1 = Disposables.empty();
  
              cd.add(d1);
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.dispose();
                  }
              };
  
              Runnable run2 = new Runnable() {
                  @Override
                  public void run() {
                      cd.delete(d1);
                  }
              };
  
              TestCommonHelper.race(run, run2, Schedulers.io());
          }
      }
  
      @Test
      public void clearDisposeRace() {
          for (int i = 0; i < 500; i++) {
              final ListCompositeDisposable cd = new ListCompositeDisposable();
  
              final Disposable d1 = Disposables.empty();
  
              cd.add(d1);
  
              Runnable run = new Runnable() {
                  @Override
                  public void run() {
                      cd.dispose();
                  }
              };
  
              Runnable run2 = new Runnable() {
                  @Override
                  public void run() {
                      cd.clear();
                  }
              };
  
              TestCommonHelper.race(run, run2, Schedulers.io());
          }
      }
  }
  