Fixed pingManager access
This commit is contained in:
parent
8694f97217
commit
b29e6e583c
@ -911,7 +911,7 @@ open class Client<CONNECTION : Connection>(
|
|||||||
val c = connection0
|
val c = connection0
|
||||||
|
|
||||||
if (c != null) {
|
if (c != null) {
|
||||||
return pingManager.ping(c, pingTimeoutSeconds, actionDispatch, responseManager, logger, function)
|
return super.ping(c, pingTimeoutSeconds, function)
|
||||||
} else {
|
} else {
|
||||||
logger.error(ClientException("Cannot send a ping when there is no connection!")) { "No connection!" }
|
logger.error(ClientException("Cannot send a ping when there is no connection!")) { "No connection!" }
|
||||||
}
|
}
|
||||||
|
@ -235,7 +235,7 @@ internal constructor(val type: Class<*>,
|
|||||||
|
|
||||||
private val streamingManager = StreamingManager<CONNECTION>(logger, messageDispatch)
|
private val streamingManager = StreamingManager<CONNECTION>(logger, messageDispatch)
|
||||||
|
|
||||||
internal val pingManager = PingManager<CONNECTION>()
|
private val pingManager = PingManager<CONNECTION>()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user