本文整理了Java中rx.Observable.toBlockingObservable()
方法的一些代码示例,展示了Observable.toBlockingObservable()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Observable.toBlockingObservable()
方法的具体详情如下:
包路径:rx.Observable
类名称: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!