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

solution: revise for the latest etherjar

Browse Source
This commit is contained in:
Igor Artamonov
2019-11-13 21:35:51 -05:00
parent 84024be68d
commit d1585287b0
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/groovy/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreamSpec.groovy
View File

@@ -74,7 +74,7 @@ class GrpcUpstreamSpec extends Specification {
) )
} }
}) })
def transport = ReactorEmeraldClient.newBuilder().forChannel(client.channel).build() def transport = ReactorEmeraldClient.newBuilder().connectUsing(client.channel).build()
def upstream = new GrpcUpstream("test", chain, client, objectMapper, transport) def upstream = new GrpcUpstream("test", chain, client, objectMapper, transport)
upstream.setLag(0) upstream.setLag(0)
upstream.init(BlockchainOuterClass.DescribeChain.newBuilder() upstream.init(BlockchainOuterClass.DescribeChain.newBuilder()
@@ -130,7 +130,7 @@ class GrpcUpstreamSpec extends Specification {
) )
} }
}) })
def transport = ReactorEmeraldClient.newBuilder().forChannel(client.channel).build() def transport = ReactorEmeraldClient.newBuilder().connectUsing(client.channel).build()
def upstream = new GrpcUpstream("test", Chain.ETHEREUM, client, objectMapper, transport) def upstream = new GrpcUpstream("test", Chain.ETHEREUM, client, objectMapper, transport)
upstream.setLag(0) upstream.setLag(0)
upstream.init(BlockchainOuterClass.DescribeChain.newBuilder() upstream.init(BlockchainOuterClass.DescribeChain.newBuilder()
@@ -190,7 +190,7 @@ class GrpcUpstreamSpec extends Specification {
finished.complete(true) finished.complete(true)
} }
}) })
def transport = ReactorEmeraldClient.newBuilder().forChannel(client.channel).build() def transport = ReactorEmeraldClient.newBuilder().connectUsing(client.channel).build()
def upstream = new GrpcUpstream("test", chain, client, objectMapper, transport) def upstream = new GrpcUpstream("test", chain, client, objectMapper, transport)
upstream.setLag(0) upstream.setLag(0)
upstream.init(BlockchainOuterClass.DescribeChain.newBuilder() upstream.init(BlockchainOuterClass.DescribeChain.newBuilder()