Skip to content

Commit

Permalink
Increase timeout
Browse files Browse the repository at this point in the history
  • Loading branch information
Sheikah45 committed Oct 13, 2023
1 parent dc76c71 commit 07e4a1b
Showing 1 changed file with 1 addition and 9 deletions.
Original file line number Diff line number Diff line change
@@ -1,9 +1,6 @@
package com.faforever.commons.lobby

import com.fasterxml.jackson.databind.ObjectMapper
import io.netty.handler.codec.LineBasedFrameDecoder
import io.netty.handler.codec.string.LineEncoder
import io.netty.handler.codec.string.LineSeparator
import io.netty.resolver.DefaultAddressResolverGroup
import org.slf4j.Logger
import org.slf4j.LoggerFactory
Expand All @@ -15,18 +12,13 @@ import reactor.core.publisher.Sinks
import reactor.core.publisher.Sinks.EmitFailureHandler
import reactor.core.publisher.Sinks.EmitResult
import reactor.core.scheduler.Schedulers
import reactor.netty.ByteBufFlux
import reactor.netty.Connection
import reactor.netty.http.client.HttpClient
import reactor.netty.http.client.WebsocketClientSpec
import reactor.netty.tcp.TcpClient
import reactor.util.retry.Retry
import reactor.util.retry.Retry.RetrySignal
import java.net.InetSocketAddress
import java.net.URI
import java.time.Duration
import java.util.function.Function
import java.util.stream.Collectors


class FafLobbyClient(
Expand Down Expand Up @@ -80,7 +72,7 @@ class FafLobbyClient(
is LoginSuccessResponse -> Mono.just(it.me)
is LoginFailedResponse -> Mono.error(LoginException(it.text))
}
}.timeout(Duration.ofSeconds(10))
}.timeout(Duration.ofSeconds(30))
.doOnError(LoginException::class.java) { kicked = true }
.doFirst {
prepareAuthenticateOnNextSession()
Expand Down

0 comments on commit 07e4a1b

Please sign in to comment.