Revert "*Switch from clearing the timeout to setting the _timeoutCanceled flag"
This reverts commit b50f7036ff
.
This commit is contained in:
parent
b7978ddc0d
commit
f9036e1c73
|
@ -55,7 +55,10 @@ export default class StreamingRpcQuery extends SimpleRpcQuery {
|
|||
|
||||
const listener = (res: Buffer) => {
|
||||
relay = relay as string;
|
||||
this._timeoutCanceled = true;
|
||||
if (this._timeoutTimer) {
|
||||
clearTimeout(this._timeoutTimer as any);
|
||||
this._timeoutTimer = null;
|
||||
}
|
||||
|
||||
if (this._canceled) {
|
||||
socket.write(pack({ cancel: true }));
|
||||
|
|
Loading…
Reference in New Issue