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) => {
|
const listener = (res: Buffer) => {
|
||||||
relay = relay as string;
|
relay = relay as string;
|
||||||
this._timeoutCanceled = true;
|
if (this._timeoutTimer) {
|
||||||
|
clearTimeout(this._timeoutTimer as any);
|
||||||
|
this._timeoutTimer = null;
|
||||||
|
}
|
||||||
|
|
||||||
if (this._canceled) {
|
if (this._canceled) {
|
||||||
socket.write(pack({ cancel: true }));
|
socket.write(pack({ cancel: true }));
|
||||||
|
|
Loading…
Reference in New Issue