diff --git a/src/main/java/it/tdlight/tdlibsession/td/direct/TestClient.java b/src/main/java/it/tdlight/tdlibsession/td/direct/TestClient.java
index d836283..90d868a 100644
--- a/src/main/java/it/tdlight/tdlibsession/td/direct/TestClient.java
+++ b/src/main/java/it/tdlight/tdlibsession/td/direct/TestClient.java
@@ -57,7 +57,7 @@ public class TestClient implements ReactorTelegramClient {
 
 	private static Message generateRandomMessage(boolean randomSender, boolean randomChat, boolean randomText) {
 		var msg = new Message();
-		msg.sender = new MessageSenderUser(312042);
+		msg.senderId = new MessageSenderUser(312042);
 		msg.chatId = 240213;
 		msg.id = incrementalMessageId.getAndIncrement();
 		var content = new MessageText();
diff --git a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java
index 40c2b90..aa36722 100644
--- a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java
+++ b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java
@@ -479,7 +479,7 @@ public class AsyncTdEasy {
 									.fromCallable(this.settings::get).single().flatMap(settings -> {
 										if (settings.isPhoneNumberSet()) {
 											return sendDirectly(new SetAuthenticationPhoneNumber(String.valueOf(settings.getPhoneNumber()),
-													new PhoneNumberAuthenticationSettings(false, false, false)
+													new PhoneNumberAuthenticationSettings(false, false, false, false, null)
 											), false);
 										} else if (settings.isBotTokenSet()) {
 											return sendDirectly(new CheckAuthenticationBotToken(settings.getBotToken()), false);
@@ -598,6 +598,7 @@ public class AsyncTdEasy {
 											.filterWhen(file -> Mono
 													.fromCallable(() -> Files.exists(file))
 													.subscribeOn(Schedulers.boundedElastic()))
+											.publishOn(Schedulers.boundedElastic())
 											.doOnNext(directory -> {
 												try {
 													if (!Files.walk(directory)