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

Single.doAfterSuccess介绍

[英]Calls the specified consumer with the success item after this item has been emitted to the downstream.

Note that the doAfterSuccess action is shared between subscriptions and as such should be thread-safe. Scheduler: doAfterSuccess does not operate by default on a particular Scheduler.

History: 2.0.1 - experimental
[中]将此项发送到下游后，使用成功项调用指定的使用者。
请注意，doAfterSuccess操作在订阅之间共享，因此应该是线程安全的。调度器：默认情况下，doAfterSuccess不会在特定的调度器上运行。
历史：2.0.1-实验性

代码示例

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

@Override
  public SingleSource<Integer> apply(Single<Integer> m) throws Exception {
    return m.doAfterSuccess(afterSuccess);
  }
});

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

@Test(expected = NullPointerException.class)
public void consumerNull() {
  Single.just(1).doAfterSuccess(null);
}

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

@Test
public void just() {
  Single.just(1)
  .doAfterSuccess(afterSuccess)
  .subscribeWith(to)
  .assertResult(1);
  assertEquals(Arrays.asList(1, -1), values);
}

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

@Test
public void dispose() {
  TestHelper.checkDisposed(PublishSubject.<Integer>create().singleOrError().doAfterSuccess(afterSuccess));
}

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

@Test
public void error() {
  Single.<Integer>error(new TestException())
  .doAfterSuccess(afterSuccess)
  .subscribeWith(to)
  .assertFailure(TestException.class);
  assertTrue(values.isEmpty());
}

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

@Test
public void justConditional() {
  Single.just(1)
  .doAfterSuccess(afterSuccess)
  .filter(Functions.alwaysTrue())
  .subscribeWith(to)
  .assertResult(1);
  assertEquals(Arrays.asList(1, -1), values);
}

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

@Test
public void errorConditional() {
  Single.<Integer>error(new TestException())
  .doAfterSuccess(afterSuccess)
  .filter(Functions.alwaysTrue())
  .subscribeWith(to)
  .assertFailure(TestException.class);
  assertTrue(values.isEmpty());
}

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

@Test
public void consumerThrows() {
  List<Throwable> errors = TestHelper.trackPluginErrors();
  try {
    Single.just(1)
    .doAfterSuccess(new Consumer<Integer>() {
      @Override
      public void accept(Integer e) throws Exception {
        throw new TestException();
      }
    })
    .test()
    .assertResult(1);
    TestHelper.assertUndeliverable(errors, 0, TestException.class);
  } finally {
    RxJavaPlugins.reset();
  }
}

代码示例来源：origin: 8enet/AppOpsX

preAppInfos.add(appInfo);
 }).observeOn(Schedulers.io()).doAfterSuccess(new Consumer<List<PreAppInfo>>() {
@Override
public void accept(@NonNull List<PreAppInfo> preAppInfos) throws Exception {

代码示例来源：origin: com.blackducksoftware.bdio/bdio-tinkerpop

@Override
public Publisher<?> persistFramedEntries(Flowable<Map<String, Object>> framedEntries) {
  return framedEntries
      .flatMapIterable(BdioDocument::toGraphNodes)
      .reduce(new NodeAccumulator(), NodeAccumulator::addNode)
      .doOnSuccess(NodeAccumulator::addEdges)
      .doAfterSuccess(NodeAccumulator::commitTx)
      .doOnError(this::handleError)
      .toFlowable();
}