diff options
| author |  Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-12-05 11:35:34 -0800 |
|---|---|---|
| committer | Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
| 2022-12-05 11:35:34 -0800 |
| commit | 0ea8de40871052842f2e342b4c452f6746691487 (patch) | |
| tree | a4e1028f90a801324966172e47b9b20533e4ad7a /src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp | |
| parent | 71293033474eea83c47b6c6948f991b1dc37ad22 (diff) | |
| download | bun-0ea8de40871052842f2e342b4c452f6746691487.tar.gz bun-0ea8de40871052842f2e342b4c452f6746691487.tar.zst bun-0ea8de40871052842f2e342b4c452f6746691487.zip | |
Make `console` an `AsyncIterable`
Diffstat (limited to 'src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp')
| -rw-r--r-- | src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp | 53 |
1 files changed, 25 insertions, 28 deletions
diff --git a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp index 8431b9fb7..854d46faa 100644 --- a/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp +++ b/src/bun.js/builtins/cpp/ReadableStreamInternalsBuiltins.cpp @@ -2621,7 +2621,7 @@ const char* const s_readableStreamInternalsReadableStreamToArrayDirectCode = const JSC::ConstructAbility s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeConstructAbility = JSC::ConstructAbility::CannotConstruct; const JSC::ConstructorKind s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeConstructorKind = JSC::ConstructorKind::None; const JSC::ImplementationVisibility s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeImplementationVisibility = JSC::ImplementationVisibility::Public; -const int s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeLength = 1650; +const int s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeLength = 1478; static const JSC::Intrinsic s_readableStreamInternalsReadableStreamDefineLazyIteratorsCodeIntrinsic = JSC::NoIntrinsic; const char* const s_readableStreamInternalsReadableStreamDefineLazyIteratorsCode = "(function (prototype) {\n" \ @@ -2632,37 +2632,34 @@ const char* const s_readableStreamInternalsReadableStreamDefineLazyIteratorsCode " var ReadableStreamAsyncIterator = async function* ReadableStreamAsyncIterator(stream, preventCancel) {\n" \ " var reader = stream.getReader();\n" \ " var deferredError;\n" \ - " try {\n" \ - " while (true) {\n" \ - " var done, value;\n" \ - " const firstResult = reader.readMany();\n" \ - " if (@isPromise(firstResult)) {\n" \ - " const result = await firstResult;\n" \ - " done = result.done;\n" \ - " value = result.value;\n" \ - " } else {\n" \ - " done = firstResult.done;\n" \ - " value = firstResult.value;\n" \ - " }\n" \ - "\n" \ - " if (done) {\n" \ - " return;\n" \ - " }\n" \ - " yield* value;\n" \ - " }\n" \ - " } catch(e) {\n" \ - " deferredError = e;\n" \ - " } finally {\n" \ - " reader.releaseLock();\n" \ - "\n" \ - " if (!preventCancel) {\n" \ - " stream.cancel(deferredError);\n" \ + " try {\n" \ + " while (true) {\n" \ + " var done, value;\n" \ + " const firstResult = reader.readMany();\n" \ + " if (@isPromise(firstResult)) {\n" \ + " ({done, value} = await firstResult);\n" \ + " } else {\n" \ + " ({done, value} = firstResult);\n" \ + " }\n" \ + "\n" \ + " if (done) {\n" \ + " return;\n" \ + " }\n" \ + " yield* value;\n" \ " }\n" \ + " } catch(e) {\n" \ + " deferredError = e;\n" \ + " } finally {\n" \ + " reader.releaseLock();\n" \ "\n" \ - " if (deferredError) {\n" \ - " throw deferredError;\n" \ + " if (!preventCancel) {\n" \ + " stream.cancel(deferredError);\n" \ " }\n" \ + "\n" \ + " if (deferredError) {\n" \ + " throw deferredError;\n" \ " }\n" \ + " }\n" \ " };\n" \ " var createAsyncIterator = function asyncIterator() {\n" \ " return ReadableStreamAsyncIterator(this, false);\n" \ |