(id, handle)
| 2120 | } |
| 2121 | |
| 2122 | [kInit](id, handle) { |
| 2123 | const state = this[kState]; |
| 2124 | state.flags |= STREAM_FLAGS_READY; |
| 2125 | |
| 2126 | const session = this[kSession]; |
| 2127 | session[kState].pendingStreams.delete(this); |
| 2128 | session[kState].streams.set(id, this); |
| 2129 | |
| 2130 | this[kID] = id; |
| 2131 | this[async_id_symbol] = handle.getAsyncId(); |
| 2132 | handle[kOwner] = this; |
| 2133 | this[kHandle] = handle; |
| 2134 | handle.onread = onStreamRead; |
| 2135 | this.uncork(); |
| 2136 | this.emit('ready'); |
| 2137 | } |
| 2138 | |
| 2139 | [kInspect](depth, opts) { |
| 2140 | if (typeof depth === 'number' && depth < 0) |
nothing calls this directly
no test coverage detected