MCPcopy Index your code
hub / github.com/di-sukharev/opencommit / _nextSteps

Method _nextSteps

out/cli.cjs:10931–10962  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

10929 return this._ongoingPromise ? transformPromiseWith(this._ongoingPromise, returnSteps, returnSteps) : returnSteps();
10930 }
10931 _nextSteps() {
10932 if (this._isFinished) {
10933 return Promise.resolve({ value: void 0, done: true });
10934 }
10935 const reader = this._reader;
10936 let resolvePromise;
10937 let rejectPromise;
10938 const promise = newPromise((resolve, reject) => {
10939 resolvePromise = resolve;
10940 rejectPromise = reject;
10941 });
10942 const readRequest = {
10943 _chunkSteps: (chunk) => {
10944 this._ongoingPromise = void 0;
10945 _queueMicrotask(() => resolvePromise({ value: chunk, done: false }));
10946 },
10947 _closeSteps: () => {
10948 this._ongoingPromise = void 0;
10949 this._isFinished = true;
10950 ReadableStreamReaderGenericRelease(reader);
10951 resolvePromise({ value: void 0, done: true });
10952 },
10953 _errorSteps: (reason) => {
10954 this._ongoingPromise = void 0;
10955 this._isFinished = true;
10956 ReadableStreamReaderGenericRelease(reader);
10957 rejectPromise(reason);
10958 }
10959 };
10960 ReadableStreamDefaultReaderRead(reader, readRequest);
10961 return promise;
10962 }
10963 _returnSteps(value) {
10964 if (this._isFinished) {
10965 return Promise.resolve({ value, done: true });

Callers 1

nextStepsMethod · 0.95

Calls 5

newPromiseFunction · 0.85
_queueMicrotaskFunction · 0.85
rejectPromiseFunction · 0.85

Tested by

no test coverage detected