fix compilation issue
This commit is contained in:
parent
7ec1d94b5d
commit
2b54a94fd5
@ -57,7 +57,7 @@ public class TestClient implements ReactorTelegramClient {
|
|||||||
|
|
||||||
private static Message generateRandomMessage(boolean randomSender, boolean randomChat, boolean randomText) {
|
private static Message generateRandomMessage(boolean randomSender, boolean randomChat, boolean randomText) {
|
||||||
var msg = new Message();
|
var msg = new Message();
|
||||||
msg.sender = new MessageSenderUser(312042);
|
msg.senderId = new MessageSenderUser(312042);
|
||||||
msg.chatId = 240213;
|
msg.chatId = 240213;
|
||||||
msg.id = incrementalMessageId.getAndIncrement();
|
msg.id = incrementalMessageId.getAndIncrement();
|
||||||
var content = new MessageText();
|
var content = new MessageText();
|
||||||
|
@ -479,7 +479,7 @@ public class AsyncTdEasy {
|
|||||||
.fromCallable(this.settings::get).single().flatMap(settings -> {
|
.fromCallable(this.settings::get).single().flatMap(settings -> {
|
||||||
if (settings.isPhoneNumberSet()) {
|
if (settings.isPhoneNumberSet()) {
|
||||||
return sendDirectly(new SetAuthenticationPhoneNumber(String.valueOf(settings.getPhoneNumber()),
|
return sendDirectly(new SetAuthenticationPhoneNumber(String.valueOf(settings.getPhoneNumber()),
|
||||||
new PhoneNumberAuthenticationSettings(false, false, false)
|
new PhoneNumberAuthenticationSettings(false, false, false, false, null)
|
||||||
), false);
|
), false);
|
||||||
} else if (settings.isBotTokenSet()) {
|
} else if (settings.isBotTokenSet()) {
|
||||||
return sendDirectly(new CheckAuthenticationBotToken(settings.getBotToken()), false);
|
return sendDirectly(new CheckAuthenticationBotToken(settings.getBotToken()), false);
|
||||||
@ -598,6 +598,7 @@ public class AsyncTdEasy {
|
|||||||
.filterWhen(file -> Mono
|
.filterWhen(file -> Mono
|
||||||
.fromCallable(() -> Files.exists(file))
|
.fromCallable(() -> Files.exists(file))
|
||||||
.subscribeOn(Schedulers.boundedElastic()))
|
.subscribeOn(Schedulers.boundedElastic()))
|
||||||
|
.publishOn(Schedulers.boundedElastic())
|
||||||
.doOnNext(directory -> {
|
.doOnNext(directory -> {
|
||||||
try {
|
try {
|
||||||
if (!Files.walk(directory)
|
if (!Files.walk(directory)
|
||||||
|
Loading…
Reference in New Issue
Block a user