From d1585287b03ee56fde500363839b057982aea147 Mon Sep 17 00:00:00 2001 From: Igor Artamonov Date: Wed, 13 Nov 2019 21:35:51 -0500 Subject: [PATCH] solution: revise for the latest etherjar --- .../dshackle/upstream/grpc/GrpcUpstreamSpec.groovy | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/test/groovy/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreamSpec.groovy b/src/test/groovy/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreamSpec.groovy index f0c3fef1..05c39dde 100644 --- a/src/test/groovy/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreamSpec.groovy +++ b/src/test/groovy/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreamSpec.groovy @@ -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) upstream.setLag(0) 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) upstream.setLag(0) upstream.init(BlockchainOuterClass.DescribeChain.newBuilder() @@ -190,7 +190,7 @@ class GrpcUpstreamSpec extends Specification { 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) upstream.setLag(0) upstream.init(BlockchainOuterClass.DescribeChain.newBuilder()