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

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

本文整理了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

/**
 * Login using an authtoken
 * @param token
 * @return BackendUser for the sent token.
 */
public static BackendUser fromToken(String token){
  return getAM().getUserFromAuthToken(token).toBlockingObservable().first();
}

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

private String JERQsymbol(final MetadataID<?> id) {
  
  switch(id.metaType()) {
  
  default:
    return "";
  case EXCHANGE:
    return id.id();
  case INSTRUMENT:
    
    final Instrument i = metaService.instrument((InstrumentID)id)
      .toBlockingObservable()
      .first()
      .get(id);
      
    String symbol = i.symbol();
    if(symbol.contains("|")) {
      symbol = i.vendorSymbols().get(VendorID.BARCHART_SHORT);
    } else {
      symbol = formatForJERQ(i.symbol());
    }
    
    return symbol;
  
  }
  
}

相关文章

Observable类方法