Skip to content

Commit 748937b

Browse files
committed
Fix
1 parent 329257b commit 748937b

1 file changed

Lines changed: 8 additions & 10 deletions

File tree

src/MTProto/MTProtoOutgoingMessage.php

Lines changed: 8 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -225,16 +225,14 @@ public function unlink(): void
225225
$this->prev->next = $this->next;
226226
unset($this->next, $this->prev);
227227

228-
}
229-
230-
$this->connection->pendingOutgoingGauge?->dec();
231-
232-
if ($this->unencrypted) {
233-
unset($this->connection->unencryptedPendingOutgoing->check_queue[$this]);
234-
} elseif ($this->specialMethodType === SpecialMethodType::UNAUTHED_METHOD) {
235-
unset($this->connection->uninitedPendingOutgoing->check_queue[$this]);
236-
} else {
237-
unset($this->connection->mainPendingOutgoing->check_queue[$this]);
228+
if ($this->unencrypted) {
229+
unset($this->connection->unencryptedPendingOutgoing->check_queue[$this]);
230+
} elseif ($this->specialMethodType === SpecialMethodType::UNAUTHED_METHOD) {
231+
unset($this->connection->uninitedPendingOutgoing->check_queue[$this]);
232+
} else {
233+
unset($this->connection->mainPendingOutgoing->check_queue[$this]);
234+
}
235+
$this->connection->pendingOutgoingGauge?->dec();
238236
}
239237
}
240238
private function check(): void

0 commit comments

Comments
 (0)