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)
     }