fix: updated removePendingRequestByNodeID

[JS-AK]

added clean and close this.pendingReqStreams when node disconnected

📝 Description

Fixed memory leak when another microservice started stream with broker.call and then switched off (with reboot for example)

Create two services, a caller and a listener
Listener implements an action stream
Caller calls the listener action stream
Make Caller fail (restart microservice) and Listener memory/stream (in src/transit.js -> this.pendingReqStreams) is not released.
Caller calls again
Caller fails again
After several retries listener may throws a out of memory exception.

PS
this.pendingRequests was empty on Listener microservice

💎 Type of change

• Bug fix (non-breaking change which fixes an issue)

🏁 Checklist:

• My code follows the style guidelines of this project
• I have performed a self-review of my own code
• I have commented my code, particularly in hard-to-understand areas

Repo for reproduce this bug
https://github.com/JS-AK/moleculer-pr-1306-example

[pkg-pr-new]

Open in Stackblitz

npm i https://pkg.pr.new/moleculerjs/moleculer@1306

commit: 6e1fd71

[icebob]

Good job, thanks!

[icebob]

@JS-AK what do you think, it can resolve #1296 as well?

[JS-AK]

@JS-AK what do you think, it can resolve #1296 as well?

it looks like that

[icebob]

Released.