From 09d30894d1cf845de6c5c88b99ba44086e94414d Mon Sep 17 00:00:00 2001
From: Svyatoslav Nikolsky <svyatonik@gmail.com>
Date: Wed, 21 Jul 2021 13:59:16 +0300
Subject: [PATCH] When restarting client, also "restart" tokio runtime (#1065)

* remember new tokio runtime on reconnect

* compilation
---
 bridges/relays/client-ethereum/src/client.rs  | 4 +++-
 bridges/relays/client-substrate/src/client.rs | 4 +++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/bridges/relays/client-ethereum/src/client.rs b/bridges/relays/client-ethereum/src/client.rs
index 1e5faa4868..c82dddcf36 100644
--- a/bridges/relays/client-ethereum/src/client.rs
+++ b/bridges/relays/client-ethereum/src/client.rs
@@ -76,7 +76,9 @@ impl Client {
 
 	/// Reopen client connection.
 	pub async fn reconnect(&mut self) -> Result<()> {
-		self.client = Self::build_client(&self.params).await?.1;
+		let (tokio, client) = Self::build_client(&self.params).await?;
+		self.tokio = tokio;
+		self.client = client;
 		Ok(())
 	}
 }
diff --git a/bridges/relays/client-substrate/src/client.rs b/bridges/relays/client-substrate/src/client.rs
index 6a486a622e..554810844a 100644
--- a/bridges/relays/client-substrate/src/client.rs
+++ b/bridges/relays/client-substrate/src/client.rs
@@ -125,7 +125,9 @@ impl<C: Chain> Client<C> {
 
 	/// Reopen client connection.
 	pub async fn reconnect(&mut self) -> Result<()> {
-		self.client = Self::build_client(self.params.clone()).await?.1;
+		let (tokio, client) = Self::build_client(self.params.clone()).await?;
+		self.tokio = tokio;
+		self.client = client;
 		Ok(())
 	}