The code doesn't compare streams I'm interested in with remote node's advertised streams. This will trigger bugs once streams are fully implemented. There should be a new property in `TCPConnection` which will be an intersection of `self.streams` with `BMConnectionPool().streams`.