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

Single.never介绍

[英]Returns a singleton instance of a never-signalling Single (only calls onSubscribe). Scheduler: never does not operate by default on a particular Scheduler.
[中]返回从不发送信号的单个（仅在订阅时调用）的单个实例。调度程序：默认情况下，从不在特定调度程序上运行。

代码示例

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

@Override
  public SingleSource<Integer> apply(Integer v)
      throws Exception {
    if (v == 1) {
      return ms;
    }
    return Single.never();
  }
}).test();

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

@Override
  public SingleSource<B<T>> apply(Single<A<T, ?>> a) {
    return Single.never();
  }
};

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

@Override
  public SingleSource<Integer> apply(Integer v)
      throws Exception {
    if (v == 1) {
        return ms;
    }
    return Single.never();
  }
}).test();

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

@Override
  public SingleSource<Integer> apply(Integer v)
      throws Exception {
    if (v == 1) {
        return ms;
    }
    return Single.never();
  }
}).test();

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

@Override
  public SingleSource<Integer> apply(Integer v)
      throws Exception {
    if (v == 1) {
      return ms;
    }
    return Single.never();
  }
}).test();

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

@Override
  public SingleSource<Integer> apply(Integer v)
      throws Exception {
    if (v == 1) {
      return ms;
    }
    return Single.never();
  }
}).test();

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

@Override
  public Publisher<Object> apply(Flowable<Object> f)
      throws Exception {
    return f
        .switchMapSingle(Functions.justFunction(Single.never()));
  }
}

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

@Override
  public Observable<Object> apply(Observable<Object> f)
      throws Exception {
    return f
        .switchMapSingle(Functions.justFunction(Single.never()));
  }
}

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

@Override
  public Observable<Object> apply(Observable<Object> f)
      throws Exception {
    return f.concatMapSingleDelayError(
        Functions.justFunction(Single.never()));
  }
}

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

@Test
public void disposed() {
  TestHelper.checkDisposed(Observable.just(1).hide()
      .concatMapSingle(Functions.justFunction(Single.never()))
  );
}

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

@Test
public void doOnSubscribe() {
  final int[] count = { 0 };
  Single.never().doOnSubscribe(new Consumer<Disposable>() {
    @Override
    public void accept(Disposable d) throws Exception {
      count[0]++;
    }
  }).test();
  assertEquals(1, count[0]);
}

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

@Test
public void source() {
  Single<Integer> c = Single.never();
  assertSame(c, ((HasUpstreamSingleSource<?>)Maybe.fromSingle(c)).source());
}

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

@Test
public void timeoutOther() throws Exception {
  Single.never()
  .timeout(100, TimeUnit.MILLISECONDS, Schedulers.io(), Single.just(1))
  .test()
  .awaitDone(5, TimeUnit.SECONDS)
  .assertResult(1);
}

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

@Test
public void timeout() throws Exception {
  Future<?> f = Single.never().toFuture();
  try {
    f.get(100, TimeUnit.MILLISECONDS);
    fail("Should have thrown");
  } catch (TimeoutException expected) {
    assertEquals(timeoutMessage(100, TimeUnit.MILLISECONDS), expected.getMessage());
  }
}

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

@Test
public void never() {
  Single.never()
  .test()
  .assertNoValues()
  .assertNoErrors()
  .assertNotComplete();
}

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

@Test
  public void mainTimedOut() {
    Single
        .never()
        .timeout(1, TimeUnit.NANOSECONDS)
        .test()
        .awaitDone(5, TimeUnit.SECONDS)
        .assertFailureAndMessage(TimeoutException.class, timeoutMessage(1, TimeUnit.NANOSECONDS));
  }
}

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

@Test
public void otherErrors() {
  Single.never()
  .timeout(1, TimeUnit.MILLISECONDS, Single.error(new TestException()))
  .test()
  .awaitDone(5, TimeUnit.SECONDS)
  .assertFailure(TestException.class);
}

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

@Test
public void mainError() {
  Observable.error(new TestException())
  .switchMapSingle(Functions.justFunction(Single.never()))
  .test()
  .assertFailure(TestException.class);
}

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

@Test
public void mainError() {
  Flowable.error(new TestException())
  .switchMapSingle(Functions.justFunction(Single.never()))
  .test()
  .assertFailure(TestException.class);
}

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

@Test(timeout = 10000)
public void cancelNoConcurrentClean() {
  TestObserver<Integer> to = new TestObserver<Integer>();
  ConcatMapSingleMainObserver<Integer, Integer> operator =
      new ConcatMapSingleMainObserver<Integer, Integer>(
          to, Functions.justFunction(Single.<Integer>never()), 16, ErrorMode.IMMEDIATE);
  operator.onSubscribe(Disposables.empty());
  operator.queue.offer(1);
  operator.getAndIncrement();
  to.cancel();
  assertFalse(operator.queue.isEmpty());
  operator.addAndGet(-2);
  operator.dispose();
  assertTrue(operator.queue.isEmpty());
}