From 499a92e4d6afc40ca13a45ae2f7d1b857cd7aa5b Mon Sep 17 00:00:00 2001
From: Igor Artamonov <igor@artamonov.ru>
Date: Thu, 11 Jul 2019 01:00:51 -0400
Subject: [PATCH] solution: rename Blockchain services

---
 build.gradle                                                | 2 +-
 src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/build.gradle b/build.gradle
index b6708b56..d701e584 100644
--- a/build.gradle
+++ b/build.gradle
@@ -44,7 +44,7 @@ configurations {
 }
 
 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-stub:${grpcVersion}"
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt
index 16abd45f..c8346ba3 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt
@@ -25,11 +25,11 @@ class BlockchainRpc(
         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)
     }
 
-    override fun streamTxStatus(request: BlockchainOuterClass.TxStatusRequest, responseObserver: StreamObserver<BlockchainOuterClass.TxStatus>) {
+    override fun subscribeTxStatus(request: BlockchainOuterClass.TxStatusRequest, responseObserver: StreamObserver<BlockchainOuterClass.TxStatus>) {
         val tx = TrackTx.TrackedTx(
                 Chain.byId(request.chainValue),
                 StreamSender(responseObserver),
@@ -40,7 +40,7 @@ class BlockchainRpc(
         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)
     }