Wait for graceful timeout

This commit is contained in:
Andrea Cavalli 2021-10-02 23:45:48 +02:00
parent f444afd465
commit 33d8347da2
1 changed files with 3 additions and 1 deletions

View File

@ -345,7 +345,9 @@ public class AsyncTdMiddleEventBusClient implements AsyncTdMiddle {
@Override
public <T extends TdApi.Object> Mono<TdResult<T>> execute(Function request, Duration timeout, boolean executeSync) {
var req = new ExecuteObject(executeSync, request, timeout);
var deliveryOptions = new DeliveryOptions(this.deliveryOptions).setSendTimeout(timeout.toMillis());
var deliveryOptions = new DeliveryOptions(this.deliveryOptions)
// Timeout + 5s (5 seconds extra are used to wait the graceful server-side timeout response)
.setSendTimeout(timeout.toMillis() + 5000);
var crashMono = crash.asMono()
.doOnSuccess(s -> logger.debug("Failed request {} because the TDLib session was already crashed", request))