@@ -122,8 +122,9 @@ class RequestManager private constructor() {
122122 " ThrowableConsumer-> " ,
123123 it.message
124124 ) // 抛异常
125- if (System .currentTimeMillis() - httpOptions.currentRequestDateTamp <= httpOptions.delaysProcessLimitTimeMillis) {
126- delay(httpOptions.delaysProcessLimitTimeMillis)
125+ val requestSpentTime = System .currentTimeMillis() - httpOptions.currentRequestDateTamp
126+ if (requestSpentTime < httpOptions.delaysProcessLimitTimeMillis) {
127+ delay(httpOptions.delaysProcessLimitTimeMillis - requestSpentTime)
127128 doThrowableConsumer(callBack, it)
128129 } else {
129130 doThrowableConsumer(callBack, it)
@@ -139,8 +140,9 @@ class RequestManager private constructor() {
139140 .flowOn(Dispatchers .Main )
140141 .collect {
141142 if (isActive) {
142- if (System .currentTimeMillis() - httpOptions.currentRequestDateTamp <= httpOptions.delaysProcessLimitTimeMillis) {
143- delay(httpOptions.delaysProcessLimitTimeMillis)
143+ val requestSpentTime = System .currentTimeMillis() - httpOptions.currentRequestDateTamp
144+ if (requestSpentTime < httpOptions.delaysProcessLimitTimeMillis) {
145+ delay(httpOptions.delaysProcessLimitTimeMillis - requestSpentTime)
144146 doBaseConsumer(callBack, it)
145147 } else {
146148 doBaseConsumer(callBack, it)
@@ -186,8 +188,9 @@ class RequestManager private constructor() {
186188 }
187189 .flowOn(Dispatchers .Main )
188190 .collect {
189- if (System .currentTimeMillis() - httpOptions.currentRequestDateTamp <= httpOptions.delaysProcessLimitTimeMillis) {
190- delay(httpOptions.delaysProcessLimitTimeMillis)
191+ val requestSpentTime = System .currentTimeMillis() - httpOptions.currentRequestDateTamp
192+ if (requestSpentTime < httpOptions.delaysProcessLimitTimeMillis) {
193+ delay(httpOptions.delaysProcessLimitTimeMillis - requestSpentTime)
191194 doBaseConsumer(callBack, it)
192195 } else {
193196 doBaseConsumer(callBack, it)
0 commit comments