From 4bb93023e8fdbc789d77187a16177fc1396d9876 Mon Sep 17 00:00:00 2001
From: Maxksim Fomenkov <maksim.fomenkov@p2p.org>
Date: Tue, 20 Sep 2022 18:38:22 +0300
Subject: [PATCH] fix build

---
 .../io/emeraldpay/dshackle/upstream/grpc/GrpcUpstream.kt      | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstream.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstream.kt
index 5b001af4..883085c3 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstream.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstream.kt
@@ -16,8 +16,10 @@
 package io.emeraldpay.dshackle.upstream.grpc
 
 import io.emeraldpay.api.proto.BlockchainOuterClass
+import io.emeraldpay.api.proto.BlockchainOuterClass.NativeSubscribeRequest
 import io.emeraldpay.api.proto.ReactorBlockchainGrpc
 import io.emeraldpay.dshackle.upstream.Upstream
+import reactor.core.publisher.Flux
 
 interface GrpcUpstream : Upstream {
 
@@ -28,4 +30,6 @@ interface GrpcUpstream : Upstream {
     fun update(conf: BlockchainOuterClass.DescribeChain)
 
     fun getBlockchainApi(): ReactorBlockchainGrpc.ReactorBlockchainStub
+
+    fun proxySubscribe(request: NativeSubscribeRequest): Flux<out Any>
 }