customInspectSymbol: kInspect,

kEmptyObject,

promisify,

deprecate,

deprecateProperty,

} = require('internal/util');

assertCrypto();

}

}

// TODO(aduh95): remove this in future semver-major

const deprecateWeight = deprecateProperty('weight',

'Priority signaling has been deprecated as of RFC 1993.',

'DEP0194');

// When a ClientHttp2Session is first created, the socket may not yet be

// connected. If request() is called during this time, the actual request

// will be deferred until the socket is ready to go.

if (options.waitForTrailers)

streamOptions |= STREAM_OPTION_GET_TRAILERS;

deprecateWeight(options);

// `ret` will be either the reserved stream ID (if positive)

// or an error code (if negative)

const ret = session[kHandle].request(headersList,

streamOptions,

options.parent | 0,

options.weight | 0,

NGHTTP2_DEFAULT_WEIGHT,

!!options.exclusive);

// In an error condition, one of three possible response codes will be

//

// Also sets the default priority options if they are not set.

const setAndValidatePriorityOptions = hideStackFrames((options) => {

if (options.weight === undefined) {

options.weight = NGHTTP2_DEFAULT_WEIGHT;

} else {

validateNumber.withoutStackTrace(options.weight, 'options.weight');

}

deprecateWeight(options);

if (options.parent === undefined) {

options.parent = 0;

}

}

// Submits a PRIORITY frame to be sent to the remote peer

// Note: If the silent option is true, the change will be made

// locally with no PRIORITY frame sent.

function submitPriority(options) {

if (this.destroyed)

return;

this[kUpdateTimer]();

// If the parent is the id, do nothing because a

// stream cannot be made to depend on itself.

if (options.parent === this[kID])

return;

this[kHandle].priority(options.parent | 0,

options.weight | 0,

!!options.exclusive,

!!options.silent);

}

// Submit a GOAWAY frame to be sent to the remote peer.

// If the lastStreamID is set to <= 0, then the lastProcStreamID will

// be used. The opaqueData must either be a typed array or undefined

}

}

priority(options) {

if (this.destroyed)

throw new ERR_HTTP2_INVALID_STREAM();

assertIsObject(options, 'options');

options = { ...options };

setAndValidatePriorityOptions(options);

const priorityFn = submitPriority.bind(this, options);

// If the handle has not yet been assigned, queue up the priority

// frame to be sent as soon as the ready event is emitted.

if (this.pending) {

this.once('ready', priorityFn);

return;

}

priorityFn();

}

sendTrailers(headers) {

if (this.destroyed || this.closed)

throw new ERR_HTTP2_INVALID_STREAM();

}

}

// TODO(aduh95): remove this in future semver-major

Http2Stream.prototype.priority = deprecate(function priority(options) {

if (this.destroyed)

throw new ERR_HTTP2_INVALID_STREAM();

}, 'http2Stream.priority is longer supported after priority signalling was deprecated in RFC 1993', 'DEP0194');

function callTimeout(self, session) {

// If the session is destroyed, this should never actually be invoked,

// but just in case...