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

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

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

Observable.toBlockingObservable介绍

[英]Converts an Observable into a BlockingObservable (an Observable with blocking operators).
[中]将可观测转换为BlockingObservable(带有阻塞运算符的可观测)。

代码示例

代码示例来源:origin: io.divide/client-java

  1. /**
  2. * Login using an authtoken
  3. * @param token
  4. * @return BackendUser for the sent token.
  5. */
  6. public static BackendUser fromToken(String token){
  7. return getAM().getUserFromAuthToken(token).toBlockingObservable().first();
  8. }

代码示例来源:origin: com.barchart.feed/barchart-feed-ddf-datalink

  1. private String JERQsymbol(final MetadataID<?> id) {
  2. switch(id.metaType()) {
  3. default:
  4. return "";
  5. case EXCHANGE:
  6. return id.id();
  7. case INSTRUMENT:
  8. final Instrument i = metaService.instrument((InstrumentID)id)
  9. .toBlockingObservable()
  10. .first()
  11. .get(id);
  12. String symbol = i.symbol();
  13. if(symbol.contains("|")) {
  14. symbol = i.vendorSymbols().get(VendorID.BARCHART_SHORT);
  15. } else {
  16. symbol = formatForJERQ(i.symbol());
  17. }
  18. return symbol;
  19. }
  20. }

相关文章

Observable类方法