rx.Observable.empty()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(263)

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

Observable.empty介绍

[英]Returns an Observable that emits no items to the Observer and immediately invokes its Observer#onCompleted method.

Scheduler: empty does not operate by default on a particular Scheduler.
[中]返回一个不向观察者发送任何项的可观察对象，并立即调用其观察者#onCompleted方法。
Scheduler:默认情况下，empty不会在特定计划程序上运行。

代码示例

代码示例来源：origin: PipelineAI/pipeline

  1. public Observable<Void> activate() {
  2.     return Observable.empty();
  3.   }
  4. }

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

  1. @Override
  2.   public Observable<Connection<ByteBuf, ByteBuf>> newConnectionRequest() {
  3.     return Observable.empty();
  4.   }
  5. };

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

  1. @Override
  2. public Observable<Void> discard(PooledConnection<?, ?> connection) {
  3.   discarded.add(connection);
  4.   return Observable.empty();
  5. }

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

  1. @Override
  2. public Observable<Void> release(PooledConnection<?, ?> connection) {
  3.   released.add(connection);
  4.   return Observable.empty();
  5. }

代码示例来源：origin: spring-projects/spring-framework

  1. @PostMapping("/observable")
  2. public Observable<Void> createWithObservable(@RequestBody Observable<Person> observable) {
  3.   return observable.toList().doOnNext(persons::addAll).flatMap(document -> Observable.empty());
  4. }

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

  1. @Override
  2. public Observable<Connection<R, W>> newConnectionRequest() {
  3.   return channelProvider.newChannel(Observable.<Channel>empty())
  4.              .map(new Func1<Channel, Connection<R, W>>() {
  5.                @Override
  6.                public Connection<R, W> call(Channel channel) {
  7.                  return ConnectionImpl.fromChannel(channel);
  8.                }
  9.              });
  10. }

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

  1. @Test(timeout = 60000)
  2. public void testWrite() throws Exception {
  3.   Observable<ByteBuf> toWrite = Observable.empty();
  4.   connRule.connection.write(toWrite);
  5.   Mockito.verify(connRule.channelOperations).write(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteString() throws Exception {
  3.   Observable<String> toWrite = Observable.empty();
  4.   connRule.connection.writeString(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeString(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteFileRegion() throws Exception {
  3.   Observable<FileRegion> toWrite = Observable.empty();
  4.   connRule.connection.writeFileRegion(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeFileRegion(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteStringAndFlushOnEach() throws Exception {
  3.   Observable<String> toWrite = Observable.empty();
  4.   connRule.connection.writeStringAndFlushOnEach(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeStringAndFlushOnEach(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteBytesAndFlushOnEach() throws Exception {
  3.   Observable<byte[]> toWrite = Observable.empty();
  4.   connRule.connection.writeBytesAndFlushOnEach(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeBytesAndFlushOnEach(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteFileRegionAndFlushOnEach() throws Exception {
  3.   Observable<FileRegion> toWrite = Observable.empty();
  4.   connRule.connection.writeFileRegionAndFlushOnEach(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeFileRegionAndFlushOnEach(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteAndFlushOnEach() throws Exception {
  3.   Observable<ByteBuf> toWrite = Observable.empty();
  4.   connRule.connection.writeAndFlushOnEach(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeAndFlushOnEach(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteBytes() throws Exception {
  3.   Observable<byte[]> toWrite = Observable.empty();
  4.   connRule.connection.writeBytes(toWrite);
  5.   Mockito.verify(connRule.channelOperations).writeBytes(toWrite);
  6.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  7. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteFileRegionWithFlushSelector() throws Exception {
  3.   Observable<FileRegion> toWrite = Observable.empty();
  4.   FlushSelector<FileRegion> flushSelector = new FlushSelector<>(1);
  5.   connRule.connection.writeFileRegion(toWrite, flushSelector);
  6.   Mockito.verify(connRule.channelOperations).writeFileRegion(toWrite, flushSelector);
  7.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  8. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteWithFlushSelector() throws Exception {
  3.   Observable<ByteBuf> toWrite = Observable.empty();
  4.   FlushSelector<ByteBuf> flushSelector = new FlushSelector<>(1);
  5.   connRule.connection.write(toWrite, flushSelector);
  6.   Mockito.verify(connRule.channelOperations).write(toWrite, flushSelector);
  7.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  8. }

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

  1. @Test(timeout = 60000)
  2. public void testWriteBytesWithFlushSelector() throws Exception {
  3.   Observable<byte[]> toWrite = Observable.empty();
  4.   FlushSelector<byte[]> flushSelector = new FlushSelector<>(1);
  5.   connRule.connection.writeBytes(toWrite, flushSelector);
  6.   Mockito.verify(connRule.channelOperations).writeBytes(toWrite, flushSelector);
  7.   Mockito.verifyNoMoreInteractions(connRule.channelOperations);
  8. }

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

  1. @Override
  2.   public void evaluate() throws Throwable {
  3.     mockPipeline = Mockito.mock(DetachedChannelPipeline.class, Mockito.RETURNS_MOCKS);
  4.     EmbeddedConnectionProvider<String, String> ecp = new EmbeddedConnectionProvider<>();
  5.     clientState = ClientState.create(mockPipeline, ecp.asFactory(), Observable.<Host>empty())
  6.                  .enableWireLogging(LogLevel.ERROR);
  7.     base.evaluate();
  8.   }
  9. };

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

  1. @Test
  2. public void testCollectOverEmptyObservable() throws Exception {
  3.   TestSubscriber<ByteBuf> t = new TestSubscriber<>();
  4.   Observable.<ByteBuf>empty()
  5.     .compose(CollectBytes.all())
  6.     .subscribe(t);
  7.   t.assertNoErrors();
  8.   t.assertCompleted();
  9.   t.assertValue(Unpooled.buffer());
  10. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void voidReturnType() throws Exception {
  3.   testVoid(null, on(TestController.class).resolveReturnType(void.class));
  4.   testVoid(Mono.empty(), on(TestController.class).resolveReturnType(Mono.class, Void.class));
  5.   testVoid(Flux.empty(), on(TestController.class).resolveReturnType(Flux.class, Void.class));
  6.   testVoid(Completable.complete(), on(TestController.class).resolveReturnType(Completable.class));
  7.   testVoid(Observable.empty(), on(TestController.class).resolveReturnType(Observable.class, Void.class));
  8.   MethodParameter type = on(TestController.class).resolveReturnType(io.reactivex.Completable.class);
  9.   testVoid(io.reactivex.Completable.complete(), type);
  10.   type = on(TestController.class).resolveReturnType(io.reactivex.Observable.class, Void.class);
  11.   testVoid(io.reactivex.Observable.empty(), type);
  12.   type = on(TestController.class).resolveReturnType(Flowable.class, Void.class);
  13.   testVoid(Flowable.empty(), type);
  14. }

内容来源于网络，如有侵权，请联系作者删除！

Observable

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Observable类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com