StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

solution: rename Blockchain services

Browse Source
This commit is contained in:
Igor Artamonov
2019-07-11 01:00:51 -04:00
parent 865335f627
commit 499a92e4d6
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle
View File

@@ -44,7 +44,7 @@ configurations {
} }
dependencies { dependencies {
compile "io.emeraldpay:emerald-grpc:0.2" compile "io.emeraldpay:emerald-grpc:0.4"
compile "io.grpc:grpc-protobuf:${grpcVersion}" compile "io.grpc:grpc-protobuf:${grpcVersion}"
compile "io.grpc:grpc-stub:${grpcVersion}" compile "io.grpc:grpc-stub:${grpcVersion}"

6
src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt
View File

@@ -25,11 +25,11 @@ class BlockchainRpc(
nativeCall.nativeCall(request, responseObserver) nativeCall.nativeCall(request, responseObserver)
} }
override fun streamHead(request: Common.Chain, responseObserver: StreamObserver<BlockchainOuterClass.ChainHead>) { override fun subscribeHead(request: Common.Chain, responseObserver: StreamObserver<BlockchainOuterClass.ChainHead>) {
streamHead.add(Chain.byId(request.type.number), responseObserver) streamHead.add(Chain.byId(request.type.number), responseObserver)
} }
override fun streamTxStatus(request: BlockchainOuterClass.TxStatusRequest, responseObserver: StreamObserver<BlockchainOuterClass.TxStatus>) { override fun subscribeTxStatus(request: BlockchainOuterClass.TxStatusRequest, responseObserver: StreamObserver<BlockchainOuterClass.TxStatus>) {
val tx = TrackTx.TrackedTx( val tx = TrackTx.TrackedTx(
Chain.byId(request.chainValue), Chain.byId(request.chainValue),
StreamSender(responseObserver), StreamSender(responseObserver),
@@ -40,7 +40,7 @@ class BlockchainRpc(
trackTx.add(tx) trackTx.add(tx)
} }
override fun streamBalance(request: BlockchainOuterClass.BalanceRequest, responseObserver: StreamObserver<BlockchainOuterClass.AddressBalance>) { override fun subscribeBalance(request: BlockchainOuterClass.BalanceRequest, responseObserver: StreamObserver<BlockchainOuterClass.AddressBalance>) {
trackAddress.add(request, responseObserver) trackAddress.add(request, responseObserver)
} }