fixes
This commit is contained in:
parent
65c0639229
commit
a7b75a1a0a
@ -110,7 +110,7 @@ class FeedLoop extends ResumableSignalLoop
|
|||||||
unset($updates[$key]);
|
unset($updates[$key]);
|
||||||
if ($update['_'] === 'updateChannelTooLong') {
|
if ($update['_'] === 'updateChannelTooLong') {
|
||||||
$this->API->logger->logger('Got channel too long update, getting difference...', \danog\MadelineProto\Logger::VERBOSE);
|
$this->API->logger->logger('Got channel too long update, getting difference...', \danog\MadelineProto\Logger::VERBOSE);
|
||||||
$this->API->updaters[$this->channelId]->resume();
|
yield $this->updater->resume();
|
||||||
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
@ -138,7 +138,7 @@ class UpdatesState
|
|||||||
*/
|
*/
|
||||||
public function pts($set = 0)
|
public function pts($set = 0)
|
||||||
{
|
{
|
||||||
if ($set !== 0) {
|
if ($set !== 0 && $set > $this->pts) {
|
||||||
$this->pts = $set;
|
$this->pts = $set;
|
||||||
}
|
}
|
||||||
return $this->pts;
|
return $this->pts;
|
||||||
@ -151,7 +151,7 @@ class UpdatesState
|
|||||||
*/
|
*/
|
||||||
public function qts($set = 0)
|
public function qts($set = 0)
|
||||||
{
|
{
|
||||||
if ($set !== 0) {
|
if ($set !== 0 && $set > $this->qts) {
|
||||||
$this->qts = $set;
|
$this->qts = $set;
|
||||||
}
|
}
|
||||||
return $this->qts;
|
return $this->qts;
|
||||||
@ -164,7 +164,7 @@ class UpdatesState
|
|||||||
*/
|
*/
|
||||||
public function seq($set = 0)
|
public function seq($set = 0)
|
||||||
{
|
{
|
||||||
if ($set !== 0) {
|
if ($set !== 0 && $set > $this->seq) {
|
||||||
$this->seq = $set;
|
$this->seq = $set;
|
||||||
}
|
}
|
||||||
return $this->seq;
|
return $this->seq;
|
||||||
|
Loading…
Reference in New Issue
Block a user