()
| 1945 | return stream; |
| 1946 | }; |
| 1947 | const reject = () => { |
| 1948 | if (reason === undefined) { |
| 1949 | if (localChan === -1) |
| 1950 | reason = CHANNEL_OPEN_FAILURE.RESOURCE_SHORTAGE; |
| 1951 | else |
| 1952 | reason = CHANNEL_OPEN_FAILURE.CONNECT_FAILED; |
| 1953 | } |
| 1954 | |
| 1955 | if (localChan !== -1) |
| 1956 | self._chanMgr.remove(localChan); |
| 1957 | |
| 1958 | self._protocol.channelOpenFail(info.sender, reason, ''); |
| 1959 | }; |
| 1960 | const reserveChannel = () => { |
| 1961 | localChan = self._chanMgr.add(); |
| 1962 |
no test coverage detected
searching dependent graphs…