From 1045dd0ef3e767e57bfad7433df84bf177de1045 Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Mon, 19 Oct 2020 16:02:16 +0200 Subject: [PATCH] Update TransferServiceImpl.java --- src/main/java/it/cavallium/TransferServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/it/cavallium/TransferServiceImpl.java b/src/main/java/it/cavallium/TransferServiceImpl.java index 02fcee6..b77325c 100644 --- a/src/main/java/it/cavallium/TransferServiceImpl.java +++ b/src/main/java/it/cavallium/TransferServiceImpl.java @@ -128,7 +128,7 @@ public class TransferServiceImpl implements TransferService { }) .build()) .then(Mono.defer(() -> { - var clientStateFlux = client.getState().skip(1).publish().autoConnect(2); + var clientStateFlux = client.getState().publish().autoConnect(2); clientStateFlux .filter(state -> state.getConstructor() == AuthorizationStateClosing.CONSTRUCTOR