本文整理了Java中io.reactivex.Single.test()方法的一些代码示例，展示了Single.test()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Single.test()方法的具体详情如下：
包路径：io.reactivex.Single
类名称：Single
方法名：test

Single.test介绍

[英]Creates a TestObserver and subscribes it to this Single. Scheduler: test does not operate by default on a particular Scheduler.
[中]创建一个TestObserver，并将其订阅到此单一。调度程序：默认情况下，测试不会在特定调度程序上运行。

代码示例

代码示例来源：origin: ReactiveX/RxJava

@Override
  public void run() {
    cached.test();
  }
};

代码示例来源：origin: ReactiveX/RxJava

@Test
public void simpleInequal() {
  Observable.sequenceEqual(Observable.just(1), Observable.just(2))
  .test()
  .assertResult(false);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void elementAtOrErrorOneElement() {
  Observable.just(1)
    .elementAtOrError(0)
    .test()
    .assertNoErrors()
    .assertValue(1);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void singleOrErrorOneElement() {
  Observable.just(1)
    .singleOrError()
    .test()
    .assertNoErrors()
    .assertValue(1);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void lastOrErrorOneElement() {
  Observable.just(1)
    .lastOrError()
    .test()
    .assertNoErrors()
    .assertValue(1);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void createNullSuccess() {
  Single.create(new SingleOnSubscribe<Object>() {
    @Override
    public void subscribe(SingleEmitter<Object> s) throws Exception {
      s.onSuccess(null);
      s.onSuccess(null);
    }
  })
  .test()
  .assertFailure(NullPointerException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
  public void emitterHasToString() {
    Single.create(new SingleOnSubscribe<Object>() {
      @Override
      public void subscribe(SingleEmitter<Object> emitter) throws Exception {
        assertTrue(emitter.toString().contains(SingleCreate.Emitter.class.getSimpleName()));
      }
    }).test().assertEmpty();
  }
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void doOnTerminateSuccessCrash() {
  Single.just(1).doOnTerminate(new Action() {
    @Override
    public void run() throws Exception {
      throw new TestException();
    }
  })
  .test()
  .assertFailure(TestException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void normal() {
  Maybe.just(1)
  .isEmpty()
  .test()
  .assertResult(false);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void doOnSuccessCrash() {
  Single.just(1)
  .doOnSuccess(new Consumer<Integer>() {
    @Override
    public void accept(Integer v) throws Exception {
      throw new TestException();
    }
  })
  .test()
  .assertFailure(TestException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void lastOrErrorError() {
  Flowable.error(new RuntimeException("error"))
    .lastOrError()
    .test()
    .assertNoValues()
    .assertErrorMessage("error")
    .assertError(RuntimeException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
@SuppressWarnings("unchecked")
public void success() {
  Maybe.just(1)
  .materialize()
  .test()
  .assertResult(Notification.createOnNext(1));
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void singleOrErrorNoElement() {
  Observable.empty()
    .singleOrError()
    .test()
    .assertNoValues()
    .assertError(NoSuchElementException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void lastOrErrorNoElement() {
  Observable.empty()
    .lastOrError()
    .test()
    .assertNoValues()
    .assertError(NoSuchElementException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void error() {
  Maybe.error(new TestException())
  .isEmpty()
  .test()
  .assertFailure(TestException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void singleOrErrorMultipleElements() {
  Flowable.just(1, 2, 3)
    .singleOrError()
    .test()
    .assertNoValues()
    .assertError(IllegalArgumentException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void delaySubscriptionSingle() throws Exception {
  Single.just(1).delaySubscription(Single.timer(100, TimeUnit.MILLISECONDS))
  .test()
  .awaitDone(5, TimeUnit.SECONDS)
  .assertResult(1);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void withPublisherError() {
  Single.just(1)
  .delaySubscription(Flowable.error(new TestException()))
  .test()
  .assertFailure(TestException.class);
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void resourceDisposedIfMapperCrashes() {
  Disposable d = Disposables.empty();
  Single.using(Functions.justCallable(d), mapperThrows, disposer)
  .test()
  .assertFailure(TestException.class);
  assertTrue(d.isDisposed());
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void delayOnSuccess() {
  final TestScheduler scheduler = new TestScheduler();
  final TestObserver<Integer> observer = Single.just(1)
    .delay(5, TimeUnit.SECONDS, scheduler)
    .test();
  scheduler.advanceTimeTo(2, TimeUnit.SECONDS);
  observer.assertNoValues();
  scheduler.advanceTimeTo(5, TimeUnit.SECONDS);
  observer.assertValue(1);
}