bestNumberFinalised for api-observable (#517)
This commit is contained in:
@@ -22,6 +22,18 @@ export default class ApiCalls extends ApiQueries {
|
||||
);
|
||||
}
|
||||
|
||||
bestNumberFinalised = (): Observable<BlockNumber | undefined> => {
|
||||
return this
|
||||
.subscribeFinalisedHead()
|
||||
.pipe(
|
||||
map((header?: Header): BlockNumber | undefined =>
|
||||
header && header.blockNumber
|
||||
? header.blockNumber
|
||||
: undefined
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
chain = (): Observable<Text | undefined> => {
|
||||
return this._api.system.chain();
|
||||
}
|
||||
@@ -42,6 +54,12 @@ export default class ApiCalls extends ApiQueries {
|
||||
return this._api.chain.getBlock(hash);
|
||||
}
|
||||
|
||||
subscribeFinalisedHead = (): Observable<Header | undefined> => {
|
||||
return this._api.chain.subscribeFinalisedHeads().pipe(
|
||||
defaultIfEmpty()
|
||||
);
|
||||
}
|
||||
|
||||
subscribeNewHead = (): Observable<Header | undefined> => {
|
||||
return this._api.chain.subscribeNewHead().pipe(
|
||||
defaultIfEmpty()
|
||||
|
||||
Reference in New Issue
Block a user