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