rx.Single.just()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(180)

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

Single.just介绍

暂无

代码示例

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

@ModelAttribute("singleBean")
public Single<TestBean> returnValueSingle() {
  return Single.just(new TestBean("Single Bean"));
}

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

@GetMapping("/single")
public Single<Person> getSingle() {
  return Single.just(new Person("Robert"));
}

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

@Test
public void rxSingleToPublisher() {
  Object source = rx.Single.just(1);
  Object target = getAdapter(rx.Single.class).toPublisher(source);
  assertTrue("Expected Mono Publisher: " + target.getClass().getName(), target instanceof Mono);
  assertEquals(Integer.valueOf(1), ((Mono<Integer>) target).block(Duration.ofMillis(1000)));
}

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

@Override
  public Single<List<HostHolder<W, R>>> call(HostUpdate<W, R> update) {
    List<HostHolder<W, R>> newList = null;
    switch (update.getAction()) {
    case Add:
      if (allowDuplicates || !currentList.contains(update.getHostHolder())) {
        newList = new ArrayList<>(currentList);
        newList.add(update.getHostHolder());
      }
      break;
    case Remove:
      newList = new ArrayList<>(currentList);
      newList.remove(update.getHostHolder());
      break;
    }
    if (null != newList) {
      currentList = newList;
    }
    return Single.just(currentList);
  }
};

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

@Test
public void bindExistingSingle() throws Exception {
  Foo foo = new Foo();
  foo.setName("Jim");
  this.bindContext.getModel().addAttribute("fooSingle", Single.just(foo));
  MethodParameter parameter = this.testMethod.annotNotPresent(ModelAttribute.class).arg(Foo.class);
  testBindFoo("foo", parameter, value -> {
    assertEquals(Foo.class, value.getClass());
    return (Foo) value;
  });
  assertSame(foo, this.bindContext.getModel().asMap().get("foo"));
}

代码示例来源：origin: Netflix/EVCache

return Single.just(returnVal);
  });
} else {
  return Single.just(Collections.<String, T> emptyMap());

代码示例来源：origin: Netflix/EVCache

private <T> Single<T> assembleChunks(String key, boolean touch, int ttl, Transcoder<T> tc, boolean hasZF, Scheduler scheduler) {
  final Stopwatch operationDuration = EVCacheMetricsFactory.getStatsTimer(appName, serverGroup, "LatencyChunk").start();
  return getChunkDetails(key, scheduler).flatMap(cd -> {
    if (cd == null) return Single.just(null);
    if (!cd.isChunked()) {
      if (cd.getData() == null) return Single.just(null);
      final Transcoder<T> transcoder = (tc == null ? (Transcoder<T>) evcacheMemcachedClient.getTranscoder() : tc);
      return Single.just(transcoder.decode((CachedData) cd.getData()));
    } else {
      final List<String> keys = cd.getChunkKeys();

代码示例来源：origin: Netflix/EVCache

public <T> Single<T> get(String key, Transcoder<T> tc, boolean _throwException, boolean hasZF, boolean chunked, Scheduler scheduler)  throws Exception {
  if (chunked) {
    return assembleChunks(key, _throwException, 0, tc, hasZF, scheduler);
  }  else if(shouldHashKey()) {
    final String hKey = getHashedKey(key);
    final Object obj = evcacheMemcachedClient.asyncGet(hKey, evcacheValueTranscoder, null).get(readTimeout.get(), TimeUnit.MILLISECONDS, _throwException, hasZF);
    if(obj instanceof EVCacheValue) {
      final EVCacheValue val = (EVCacheValue)obj;
      if(val == null || !(val.getKey().equals(key))) {
        EVCacheMetricsFactory.increment(appName, null, serverGroup.getName(), appName + "-KEY_HASH_COLLISION");
        return null;
      }
      final CachedData cd = new CachedData(val.getFlags(), val.getValue(), CachedData.MAX_SIZE);
      if(tc == null) {
        return Single.just((T)evcacheMemcachedClient.getTranscoder().decode(cd));
      } else {
        return Single.just(tc.decode(cd));
      }
    } else {
      return null;
    }
  } else {
    return evcacheMemcachedClient.asyncGet(key, tc, null)
      .get(readTimeout.get(), TimeUnit.MILLISECONDS, _throwException, hasZF, scheduler);
  }
}

代码示例来源：origin: Netflix/EVCache

public <T> Single<T> get(String key, Transcoder<T> tc, boolean _throwException, boolean hasZF, Scheduler scheduler) {
  try {
    if (!validateNode(key, _throwException)) {
      if(ignoreInactiveNodes.get()) {
        EVCacheMetricsFactory.increment(appName, null, serverGroup.getName(), appName + "-IGNORE_INACTIVE_NODES");
        return pool.getEVCacheClientForReadExclude(serverGroup).get(key, tc, _throwException, hasZF, enableChunking.get(), scheduler);
      } else {
        return Single.just(null);
      }
    }
    return get(key, tc, _throwException, hasZF, enableChunking.get(), scheduler);
  } catch (Throwable e) {
    return Single.error(e);
  }
}

代码示例来源：origin: Netflix/EVCache

return Single.just(data);
}).map(data -> {
  if (data != null) {

代码示例来源：origin: Netflix/EVCache

return Single.just(data);
}).map(data -> {
  if (data != null) {

代码示例来源：origin: Netflix/EVCache

return Single.just((T)_client.getTranscoder().decode(cd));
} else {
  return Single.just(tc.decode(cd));
    return Single.just((T)_client.getTranscoder().decode(cd));
  } else {
    return Single.just(tc.decode(cd));

代码示例来源：origin: mercyblitz/segmentfault-lessons

private static void demoSingle() {
  Single.just("Hello,World") // 仅能发布单个数据
      .subscribeOn(Schedulers.io()) // 在 I/O 线程执行
      .subscribe(RxJavaDemo::println) // 订阅并且消费数据
  ;
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void s1s2IsDisposed() {
  toV2Single(rx.Single.just(1))
  .subscribe(new io.reactivex.SingleObserver<Integer>() {
    @Override
    public void onSubscribe(io.reactivex.disposables.Disposable d) {
      assertFalse(d.isDisposed());
    }
    @Override
    public void onSuccess(Integer v) {
    }
    @Override
    public void onError(Throwable e) {
    }
  });
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void s1m2IsDisposed() {
  toV2Maybe(rx.Single.just(1))
    .subscribe(new io.reactivex.MaybeObserver<Integer>() {
      @Override
      public void onSubscribe(io.reactivex.disposables.Disposable d) {
        assertFalse(d.isDisposed());
      }
      @Override
      public void onSuccess(Integer v) {
      }
      @Override
      public void onComplete() {
      }
      @Override
      public void onError(Throwable e) {
      }
    });
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void s1s2ErrorNull() {
  toV2Single(rx.Single.just(null)).test()
  .assertFailure(NullPointerException.class);
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void s1m2ErrorNull() {
  toV2Maybe(rx.Single.just(null)).test()
    .assertFailure(NullPointerException.class);
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void s1m2Normal() {
  toV2Maybe(rx.Single.just(1)).test()
    .assertResult(1);
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void s1s2Normal() {
  toV2Single(rx.Single.just(1)).test()
  .assertResult(1);
}

代码示例来源：origin: akarnokd/RxJava2Interop

@Test
public void st2ToSt1() {
  SingleTransformer<Integer, Integer> transformer = new SingleTransformer<Integer, Integer>() {
    @Override
    public Single<Integer> apply(Single<Integer> o) {
      return o.map(new Function<Integer, Integer>() {
        @Override
        public Integer apply(Integer v) {
          return v + 1;
        }
      });
    }
  };
  rx.Single.just(1)
  .compose(toV1Transformer(transformer))
  .test()
  .assertResult(2);
}

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

Single

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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