danog/MadelineProto
1
0
Fork 0
mirror of https://github.com/danog/MadelineProto.git synced 2024-12-02 12:57:49 +01:00
Code Issues Projects Releases Wiki Activity

Update deps

Browse Source
This commit is contained in:
Daniil Gentili 2023-09-30 15:48:52 +02:00
parent dcb5816495
commit 5be1947e6d
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
composer.json
View File

@ -50,7 +50,7 @@
"league/uri": "^7", "league/uri": "^7",
"danog/ipc": "^1", "danog/ipc": "^1",
"amphp/log": "^2", "amphp/log": "^2",
"danog/loop": "^1", "danog/loop": "^1.1.0",
"phpseclib/phpseclib": "^3.0.22", "phpseclib/phpseclib": "^3.0.22",
"amphp/redis": "^2", "amphp/redis": "^2",
"psr/http-factory": "^1.0", "psr/http-factory": "^1.0",

4
src/Connection.php
View File

@ -516,8 +516,8 @@ final class Connection
unset($body); unset($body);
} }
$this->pendingOutgoing[$this->pendingOutgoingKey++] = $message; $this->pendingOutgoing[$this->pendingOutgoingKey++] = $message;
if ($flush && isset($this->writer)) { if ($flush) {
$this->writer->resume(); $this->flush();
} }
$this->connect(); $this->connect();
$promise->await(); $promise->await();

2
src/MTProtoSession/CallHandler.php
View File

@ -148,7 +148,7 @@ trait CallHandler
$promises[] = async($this->methodCallAsyncWrite(...), $method, $single_args, $new_aargs); $promises[] = async($this->methodCallAsyncWrite(...), $method, $single_args, $new_aargs);
} }
if (!isset($aargs['postpone'])) { if (!isset($aargs['postpone'])) {
$this->writer->resume(); $this->flush();
} }
return new WrappedFuture(async(fn () => \array_map( return new WrappedFuture(async(fn () => \array_map(
fn (WrappedFuture $f) => $f->await(), fn (WrappedFuture $f) => $f->await(),

2
src/MTProtoSession/ResponseHandler.php
View File

@ -162,7 +162,7 @@ trait ResponseHandler
} }
$this->new_incoming = []; $this->new_incoming = [];
if ($this->pendingOutgoing) { if ($this->pendingOutgoing) {
$this->writer->resume(); $this->flush();
} }
} }
/** /**