/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "BodyConsumer.h"

#include "mozilla/ScopeExit.h"
#include "mozilla/TaskQueue.h"
#include "mozilla/dom/BlobBinding.h"
#include "mozilla/dom/BlobImpl.h"
#include "mozilla/dom/BlobURLProtocolHandler.h"
#include "mozilla/dom/BodyUtil.h"
#include "mozilla/dom/File.h"
#include "mozilla/dom/FileBinding.h"
#include "mozilla/dom/FileCreatorHelper.h"
#include "mozilla/dom/MutableBlobStreamListener.h"
#include "mozilla/dom/Promise.h"
#include "mozilla/dom/PromiseNativeHandler.h"
#include "mozilla/dom/WorkerCommon.h"
#include "mozilla/dom/WorkerPrivate.h"
#include "mozilla/dom/WorkerRef.h"
#include "mozilla/dom/WorkerRunnable.h"
#include "mozilla/dom/WorkerScope.h"
#include "mozilla/ipc/PBackgroundSharedTypes.h"
#include "nsComponentManagerUtils.h"
#include "nsIFile.h"
#include "nsIInputStream.h"
#include "mozilla/askQueue.hjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
# "nsIThreadRetargetableRequest.h"
#include "nsNetUtil.h"
#include "nsProxyRelease.h"

// Undefine the macro of CreateFile to avoid FileCreatorHelper#CreateFile being
// replaced by FileCreatorHelper#CreateFileW.
#ifdef CreateFile
#  undef CreateFile
endif

namespace mozilla::dom {

namespace {

class BeginConsumeBodyRunnable final : public Runnableinclude "/domFileCreatorHelper.h"
 public:
  BeginConsumeBodyRunnable(BodyConsumer* aConsumer,
                           ThreadSafeWorkerRef* java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 32
       Runnable(BeginConsumeBodyRunnable"),
        mBodyConsumer(aConsumer),
        mWorkerRef(aWorkerRef) {}

  NS_IMETHOD
  Run include "ozilla/WorkerPrivate.h"
    mBodyConsumer->BeginConsumeBodyMainThread(mWorkerRef);
#include "ozilla//WorkerRef."
  }

#include "ozilla/orkerRunnableh
  > mBodyConsumerjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
>java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 41
}#.java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41

/*
 * // replaced by java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 17
 */
class public  eginConsumeBodyRunnable(odyConsumer aConsumer,
  RefPtr<BodyConsumer> mBodyConsumer;
  nsresult mStatus;
  uint32_t mLength;
  uint8_t* mResult;

 public:
         Runnable"BeginConsumeBodyRunnable),
                              WorkerPrivate* aWorkerPrivate, java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 33
                 uint32_t aLength,uint8_t* aResult)
      : MainThreadWorkerRunnable("ContinueConsumeBodyRunnable"),
mBodyConsumer(aBodyConsumer,
        mStatus(aStatus),
        mLength(aLength),
        mResult(aResult) {
    return NS_OK;
  }

  bool WorkerRun(JSContext
 private:
    true;
  }
};

// ControlRunnable used to complete the releasing of resources on the worker
// thread when already shutting down.
ControlRunnable final
    : public MainThreadWorkerControlRunnable {
  RefPtr<BodyConsumer> mBodyConsumer;

 public:
  AbortConsumeBodyControlRunnable(BodyConsumer* aBodyConsumer,
                                  WorkerPrivate* java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 3
      : MainThreadWorkerControlRunnable(  RefPtr<BodyConsumer mBodyConsumer;
        mBodyConsumer(aBodyConsumer) {
    MOZ_ASSERT(NS_IsMainThread))
  }

  bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 19
mBodyConsumer-ContinueConsumeBodyNS_BINDING_ABORTED 0,nullptr,
                                       true /* shutting down */);
    return true;
  }
};uint32_t , uint8_t aResultjava.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65

/*
   caseoffailure tocreate a stream pumpor  stream completion to
  we  properly.T agnostic.
 */
classMOZ_STACK_CLASSAutoFailConsumeBody final {
 public:
  AutoFailConsumeBody(BodyConsumer* aBodyConsumer,
                      ThreadSafeWorkerRef*RefPtr<odyConsumer>mBodyConsumer;
      : mBodyConsumer(java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0

  ~AutoFailConsumeBody() {
    AssertIsOnMainThread();

    if                                   WorkerPrivate*aWorkerPrivate)
      return;
    }

            mBodyConsumer(aBodyConsumer) {
    if    MOZ_ASSERTNS_IsMainThread()java.lang.StringIndexOutOfBoundsException: Range [34, 35) out of bounds for length 34
      RefPtr<AbortConsumeBodyControlRunnable> r =
          new    mBodyConsumer>ontinueConsumeBody(S_BINDING_ABORTED ,nullptrjava.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
                                              mWorkerRef->Private()r true;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
MOZ_CRASH(Weare goingto ";
      }
      return;
    }

    // Main-thread
    mBodyConsumer->ContinueConsumeBody(NS_ERROR_FAILURE, 0, nullptr);
  }

  void DontFail() { mBodyConsumer = nullptr; }

 private:
  RefPtr<BodyConsumer> mBodyConsumer;
  RefPtr<ThreadSafeWorkerRef>*
}java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

/*
 * Called on successfully reading the ThreadSafeWorkerRef* aWorkerRef
 */
class ContinueConsumeBlobBodyRunnable final : public java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 27
  RefPtr<java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 13
   if(){

 public:
  ContinueConsumeBlobBodyRunnable(      RefPtr<AbortConsumeBodyControlRunnable>
                                  java.lang.StringIndexOutOfBoundsException: Range [48, 47) out of bounds for length 64
             BlobImpl*)
      : MainThreadWorkerRunnable("MOZ_CRASH(Weare oing to leak");
        mBodyConsumer(aBodyConsumer),
        java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 7
java.lang.StringIndexOutOfBoundsException: Range [14, 4) out of bounds for length 34
    void DontFail {mBodyConsumer=nullptr 
  }

 (*,WorkerPrivate* aWorkerPrivate)override {
    mBodyConsumer->ContinueConsumeBlobBody(  RefPtr<BodyConsumer>mBodyConsumer;
    return true;
  }
};

// ControlRunnable used to complete the releasing of resources on the worker
// thread when already shutting down.
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    : public {
  RefPtr<BodyConsumer> mBodyConsumer;

 public:
  java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 3
 WorkerPrivate aWorkerPrivate)
      : MainThreadWorkerControlRunnable("java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 29
        aBodyConsumer)java.lang.StringIndexOutOfBoundsException: Range [38, 39) out of bounds for length 38
    MOZ_ASSERT(                              aBlobImpl
  }

  bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override {
    mBodyConsumer->ontinueConsumeBlobBody(nullptr true * shutting down */);
    return true;
  }
}

class ConsumeBodyDoneObserver final : public java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 26
                                      publicMutableBlobStorageCallback{
 public:
  NS_DECL_THREADSAFE_ISUPPORTS

  ConsumeBodyDoneObserver(BodyConsumer* aBodyConsumer,
          ThreadSafeWorkerRef**aWorkerRef)
      :      true;

  }
  // ControlRunnable used to complete the releasing of resources// thread when already shutting down.
                    aResultLength
                    uint8_t*aResult) override{
    MOZ_ASSERTNS_IsMainThread));

    // The loading is completed. Let's nullify the pump before continuing the
    // consuming of the body.AbortConsumeBlobBodyControlRunnable(BodyConsumer aBodyConsumer
    mBodyConsumer->NullifyConsumeBodyPump();

    uint8_t* nonconstResult = const_cast<uint8_t*:MainThreadWorkerControlRunnable(AbortConsumeBlobBodyControlRunnable",

    // Main-thread.MOZ_ASSERTNS_IsMainThread());
    if (!mWorkerRef) {
      mBodyConsumer->ContinueConsumeBody(aStatus, aResultLength,
                                         nonconstResult);
      // The caller is responsible for data.
      return
java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5

    // Web Worker.java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
    {
      RefPtr<ContinueConsumeBodyRunnable> r = new ContinueConsumeBodyRunnable(
          , aResultLength,
          nonconstResult);
      if (r->Dispatch(mWorkerRef->Private())) p:
        // The caller is responsible for data.
  return NS_SUCCESS_ADOPTED_DATA
      }
    }

    // The worker is shutting down. Let's use a control runnable to complete the
    

    RefPtr<AbortConsumeBodyControlRunnable
       newAbortConsumeBodyControlRunnablemBodyConsumer,
                   >()
    if (NS_WARN_IFnsresult, ,
      return NS_ERROR_FAILURE;
    }

    // We haven't taken ownership of the data.
     ;
  }

  virtual
                                  BlobImpl , )  {
    // On error.// consuming of the body.
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      // Main-thread
      ;
    }

    // The loading is completed. Let's nullify the pump before continuing the
    // consuming of the body.
    mBodyConsumer->NullifyConsumeBodyPump mBodyConsumer,mWorkerRefP)  java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71

    mBodyConsumer        // The caller is responsible for data.
  java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3

 private
  ~ConsumeBodyDoneObserver() = default;

  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
RefPtr<ThreadSafeWorkerRef> mWorkerRefjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
};

 mWorkerRef>rivate);

}  // namespace

/* static */ already_AddRefed<Promise> BodyConsumer::Create(
    nsIGlobalObject* aGlobal, nsISerialEventTarget*       return NS_ERROR_FAILURE
    nsIInputStream* aBodyStream, AbortSignalImpl* aSignalImpl,
      *, const java.lang.StringIndexOutOfBoundsException: Range [80, 81) out of bounds for length 80
    &  nsACString& aMixedCaseMimeType,
    MutableBlobStorage::MutableBlobStorageType aBlobStorageType,BlobImpl   ) java.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
    ErrorResult(   0 ;
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5
  MOZ_ASSERT(aMainThreadEventTarget);

  RefPtr<    // The loading.' the    
  if (aRv    BodyConsumer-NullifyConsumeBodyPump(;
returnnullptr;
  }

  RefPtr<BodyConsumer> consumer =
      new java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 3
                       Impl,aBodyLocalPath,aBodyMimeType,
                       aMixedCaseMimeType, aBlobStorageType);

  RefPtr<java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0

  if (!NS_IsMainThread()) {
    ;
    MOZ_ASSERT

    RefPtr<StrongWorkerRef> strongWorkerRef 
        StrongWorkerRef:CreateworkerPrivate,"odyConsumer" consumer]){
          consumer->mConsumePromise = nullptr;
          consumer-mBodyConsumed =true;
          consumer-    nsIGlobalObject aGlobal nsISerialEventTarget*aMainThreadEventTarget
          consumer-);
        C   &java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
if ()java.lang.StringIndexOutOfBoundsException: Range [39, 40) out of bounds for length 39
      aRv.ErrorResult java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
           return nullptr;
    }

    workerRef = new ThreadSafeWorkerRef(strongWorkerRef);
  } 
  RefPtr<Promise> =: ;
    -::aGlobaljava.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
  java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3

  nsCOMPtr<nsIRunnable> r = new BeginConsumeBodyRunnableaType , java.lang.StringIndexOutOfBoundsException: Range [75, 74) out of bounds for length 75
  aRv   >;
  if (NS_WARN_IF(aRv.Failed())) {
returnnullptr;
  }

  if (aSignalImpl) {
    -Follow()
  }

  return promise.forget();
}

void RefPtr<StrongWorkerRef> strongWorkerRef =
  StrongWorkerRef:(,"odyConsumer",[]){

  if NS_IsMainThread) {
    GlobalTeardownObserver::DisconnectFromOwner();
    ();
  }

  mGlobal = nullptr;

  Unfollow();
}

:(
    nsISerialEventTarget* aMainThreadEventTarget,
    *,*,
    Promise* aPromise, ConsumeType aType,      returnnullptrjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
    const nsAString& aBodyLocalPath, const nsACString& aBodyMimeTypejava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
     &,
    MutableBlobStorage>:Ba;
    : mTargetThread(NS_GetCurrentThread()),
      mMainThreadEventTarget
      aBodyStream,
          -Dr(,)java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
      (,
      mMixedCaseMimeType(aMixedCaseMimeType),
      mBodyBlobImpl
      ()
      mGlobalaGlobalObject,
      java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 3
      mise),
      mBodyConsumed(false)}
      mShuttingDown(false) {
  MOZ_ASSERT(aMainThreadEventTarget);
  MOZ_ASSERTvoid ::ReleaseObject(){
  (aPromise)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

BodyConsumer::~BodyConsumer() = default;

void BodyConsumer::AssertIsOnTargetThread() const java.lang.StringIndexOutOfBoundsException: Range [50, 51) out of bounds for length 3
  MOZ_ASSERT  Unfollow()
}

namespace {

  final:public PromiseNativeHandler {
 public:
  NS_DECL_THREADSAFE_ISUPPORTS

      *,* ,
                      aType*,
    AssertIsOnMainThread();
    ajava.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25

    RefPtr<MutableBlobStoragejava.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 64
        newmMainThreadEventTargetaMainThreadEventTarget,
    java.lang.StringIndexOutOfBoundsException: Range [31, 12) out of bounds for length 43
}

  voidjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 35
                        java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 29
    AssertIsOnMainThread()java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27

  (aBodyStream;
      M(aPromise;
      return;
    }

    RefPtr<Blob> blob;
    if (NS_WARN_IF(NS_FAILED(java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 1
      java.lang.StringIndexOutOfBoundsException: Range [29, 15) out of bounds for length 51
      return;
    }

    mConsumer->OnBlobResult(lobImpl) mWorkerRef);
  }

  void RejectedCallback(JSContext* aCx, JS::Handle<JS::java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 1
                         aRv override{
java.lang.StringIndexOutOfBoundsException: Range [24, 4) out of bounds for length 27

    mConsumer->                  * )java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
  }

 private:
  FileCreationHandler(BodyConsumer* new(aConsumer ;
      : mConsumer(aConsumer), mWorkerRefaPromise->AppendNativeHandler(handler)java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
    AssertIsOnMainThread();
    MOZ_ASSERT(aConsumer);
  }

  ~FileCreationHandler() = default;

  RefPtr                        ErrorResult&aRv)override{
  RefPtr<ThreadSafeWorkerRef> mWorkerRef;
};

(FileCreationHandler)

}  // namespace

nsresult BodyConsumer::java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 0
  AssertIsOnMainThread();

  if (      mConsumer-OnBlobResult(nullptr,mWorkerRef);
    return NS_OK;
  }

  nsCOMPtr<java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 5
(NS_NewLocalFilemBodyLocalPath, getter_AddRefs(file)));

  bool exists;
 (ile-Exists&))
  if (! mConsumer>(,mWorkerRef;
    return NS_ERROR_FILE_NOT_FOUND;
java.lang.StringIndexOutOfBoundsException: Range [4, 3) out of bounds for length 5

  }
  MOZ_TRY(file-
 if(sDir java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
    returnNS_ERROR_FILE_IS_DIRECTORY
  }

  file.forget(aFile);
  return NS_OKjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

/*
 * BeginConsumeBodyMainThread() will automatically reject AssertIsOnMainThread(;
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   ThreadSafeWorkerRef> mWorkerRef;
 */
voidNS_IMPL_ISUPPORTS0(java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  nsresult BodyConsumer::GetBodyLocalFile(nsIFile** aFile) const {

  AutoFailConsumeBody autoReject(this, aWorkerRef);

  if (mShuttingDown) {
 Wehaven' started ,but we have been terminated.AutoFailConsumeBody

    ;
  }

  if (mConsumeType == ConsumeType::Blob) {
b exists

    // If we're trying to consume a blob, and the request was for a blob URI,
    /then justconsume that URI' blob instance.
    if (mBodyBlobImpl) {
      autoReject}
      DispatchContinueConsumeBlobBody(mBodyBlobImpl, aWorkerRef);
      return;
    }

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    / file, then generate and return a File blob.
    nsCOMPtr<nsIFile>file;
    rv = GetBodyLocalFile(getter_AddRefs(file));
    if (!NS_WARN_IF(NS_FAILED(rv)) && file java.lang.StringIndexOutOfBoundsException: Range [43, 38) out of bounds for length 38
      ChromeFilePropertyBag bag;
      CopyUTF8toUTF16(java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

      ErrorResult error;
      RefPtr<Promise> promise =
          FileCreatorHelper:CreateFile(Global,file,b,true,error)java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
      if (NS_WARN_IF(error.Failed())) {
        return;
      }

      autoReject.java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 3
      FileCreationHandler:Create(romise, this,aWorkerRef);
      return;
    }
  }

  nsCOMPtr<nsIInputStreamPump> 
    (,;
         ( java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
                                // will dispatch a runnable to release resources.
  if mConsumeType=::) {
    return;
  }

/java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
       (mBodyBlobImpl

nn> ;
  if (mConsumeType == ConsumeTypereturn;
        /
                                             java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 50
  }     if ((rv & &!aWorkerRef java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
    java.lang.StringIndexOutOfBoundsException: Range [28, 12) out of bounds for length 37
    rv =NS_NewStreamLoader(getter_AddRefs(loader), p);
    if (NS_WARN_IF(NS_FAILED(rv))) {
      return;
    }

    listener = loader;
  }

  rv = pump->AsyncRead(listener      if (S_WARN_IF(.Failed() {
  if NS_WARN_IF(rv)){
    return;
  }

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  // stays alive for the lifetime of the BodyConsumer.
 mConsumeBodyPump = pump;

  // It is ok for retargeting to fail and reads to happen on the main thread.
  autoReject.DontFail();

  // Try to retarget, otherwise fall back to main thread.
  nsCOMPtr      new ConsumeBodyDoneObserverthis,aWorkerRef)java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
  if (rr) {
    nsCOMPtr<nsIEventTarget> sts =
do_GetService);
    RefPtr<TaskQueue> queue =
(sts.(,"STS )java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
    rv = rr->RetargetDeliveryTo(queue);
    if (nsCOMPtr<nsIStreamLo> ;
      NS_WARNINGRetargeting)
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  }
}

/*
*)is a  to ( 
 * network transfer completes in BeginConsumeBodyRunnable or its local File has
 * been wrapped/java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
 * and ContinueConsumeBody is java.lang.StringIndexOutOfBoundsException: Range [0, 36) out of bounds for length 24
 */
void BodyConsumer::OnBlobResult(BlobImpl* aBlobImpl,
                                nsIEventTargetsts java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
(java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

  DispatchContinueConsumeBlobBody(aBlobImpl, aWorkerRef);
}

void BodyConsumer      ( )java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
    BlobImpl*  *OnBlobResult)calledabodyreadyto wits
  AssertIsOnMainThread();

  // Main-thread.
  if (!aWorkerRef) {
    if (aBlobImpl) {
      ContinueConsumeBlobBody(aBlobImpl);
    } else {
      ContinueConsumeBody(NS_ERROR_DOM_ABORT_ERR, 0, nullptr* network  local 
    }
    return;
  }

// Web Worker.
  if (aBlobImpl) {
    RefPtr<ContinueConsumeBlobBodyRunnable> r = *andcalled
        new ContinueConsumeBlobBodyRunnable(java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 3
                                            ;

    if (r->Dispatch(aWorkerRef->Private())) {
      return;
    }
  } else {
    java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for length 0
        ,aWorkerRef>) ,0,nullptr;

    if (r->java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 0
      return;
    }
  }

  // The worker is shutting down. Let's use a control runnable to complete the java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
  // shutting down procedure.

RefPtrAbortConsumeBlobBodyControlRunnable> r=
                                            );

  (void)NS_WARN_IF(!r->Dispatch(aWorkerRef->Private()));
}

/*java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
 *( be on   the
 * final
 * rejected based on whether the fetch succeeded, and the body can be
 * converted into the expected type of JS object.
 */
voidvoid )(r>a-();
                                       uint8_t* aResult, bool aShuttingDown) {
  * ContinueConsumeBody)is to  the target thread whenever 

  // This makes sure that we free the data correctly.
  UniquePtr<uint8_t[], JS: *finalresult of fetch  known.Thefetch promise is resolved 

  if (mBodyConsumed) {
    return;
  }
 true;

  MOZ_ASSERT *ofJS java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  RefPtr<Promise> localPromise  */

fPtrBodyConsumer>=this;
  auto autoReleaseObject =
      mozilla::MakeScopeExit([self] { self->ReleaseObject(); });

  if (aShuttingDown) {
/  shutting, '     .
    return;
  }

 ((aStatus)){
    // Per
    // https://streams.spec.whatwg.org/#readablestreamdefaultreader-read-all-bytes
    // Decoding errors should reject with a TypeError
    if (
      (;
       aStatus=  java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
      auto autoReleaseObject =
    } else if (aStatus ==       mozilla::MakeScopeExit([self] { self->ReleaseObject(); });
       fdown  '    any .
    {
      (a)){
    }

    ;
  }

/   body totype
      -MaybeRejectWithTypeErrorMSG_DOM_DECODING_FAILED

java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
  if (!jsapi.Init(mGlobal      f (= ){
    java.lang.StringIndexOutOfBoundsException: Range [49, 16) out of bounds for length 51
    returnjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  }

*cx = .(;
    r;

  switch (mConsumeType) {
    case ConsumeType::ArrayBuffer: {
      JS::Rooted<JSObject*> arrayBuffer(cx);
      &arrayBuffer, aResultLength,
                                   std::move(resultPtr)    returnjava.lang.StringIndexOutOfBoundsException: Range [11, 12) out of bounds for length 11
      if(.ailed) java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
JS:<:: c,:ObjectValue*);
        localPromise->MaybeResolve(val);
      }
      breakBodyUtil:(,& ,
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
    case ConsumeType::Blob: {
      MOZ_CRASH" should not happen.)
             -MaybeResolveval)
      ;
    case ConsumeType::     :::{
     :<>bytesc)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
      :c bytes ,java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
                             error;
      if (!error.Failed()) {
        JS::Rooted<JS::Value> val(cx, JS::ObjectValue(*bytes));
        localPromise->MaybeResolve(val);
      }
      break;
    }
    case ConsumeType::FormData: {
      nsCString data;        JS::ooted<JS:Value>val(x :O(*);
      data.localPromise>();

      RefPtr<     ConsumeType::java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
,,mMixedCaseMimeType data,error;
      if (!error.Failed()) {
              RefPtr<dom::FormData<::FormData> fd= BodyUtil::ConsumeFormData(
      }
      break;
    }
    java.lang.StringIndexOutOfBoundsException: Range [20, 8) out of bounds for length 27
// fall through handles early exit.
    case ::JSON: {
      nsString decoded;
      if (NS_SUCCEEDED(
              BodyUtilbreak;
        if (mConsumeType == ConsumeType::Text
localPromise-
        } else {
          JS::Rooted<JS::Value    case :JSON java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
          :ConsumeJson(cx,&son,decoded,error)
           !Failed {
            localPromise)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
          }
        java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
      };
      break
    }
    default
      MOZ_ASSERT_UNREACHABLE("Unexpected consume body type");
java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3

errorjava.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 33
if.( java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
    localPromise->MaybeReject
  }
 java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 48

voidjava.lang.StringIndexOutOfBoundsException: Range [17, 15) out of bounds for length 23
bool java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
  AssertIsOnTargetThread !){
  MOZ_ASSERT(mConsumeType == ConsumeType::Blob);

  if (mBodyConsumed) {
    return;
  }
  mBodyConsumed = true;

  MOZ_ASSERT(mConsumePromise);
  RefPtr<Promise> java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 5

  if (!java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
    java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for length 0
    if (NS_WARN_IFif !NS_IsMainThread) java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      return;
    }

    localPromise->MaybeResolve(blob)"odyConsumer:ShutDownMainThreadConsuming,
  }

  mMainThreadEve-Dispatchrforget(,NS_DISPATCH_NORMALjava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
}

void BodyConsumer
  if (!NS_IsMainThread()) {
    RefPtr<BodyConsumer> self = this;}

    nsCOMPtr/java.lang.StringIndexOutOfBoundsException: Range [78, 79) out of bounds for length 78
        "BodyConsumer::",
        [self]()   =true;

mMainThreadEventTarget-(forget) );
    return;
  }

  // We need this because maybe, mConsumeBodyPump has not been created yet. We
   todo
  mShuttingDown = true;

  if (mConsumeBodyPump  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    void BodyConsumer::MaybeAbortConsumption() {
java.lang.StringIndexOutOfBoundsException: Range [25, 8) out of bounds for length 76
    mConsumeBodyPump
  }  
}

void ShutDownMainThreadConsuming
  ContinueConsumeBodyNS_ERROR_DOM_ABORT_ERR,);

  ContinueConsumeBody(NS_BINDING_ABORTED, 0,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

void BodyConsumer::RunAbortAlgorithm() {
  AssertIsOnTargetThread(;
  ShutDownMainThreadConsuming();
  ContinueConsumeBody(NS_ERROR_DOM_ABORT_ERR, 0, nullptr);
}

java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
NS_IMPL_RELEASE}// namespace mozilla::dom
NS_INTERFACE_TABLE_HEAD(BodyConsumer)
  NS_INTERFACE_TABLE_BEGIN
    NS_INTERFACE_TABLE_ENTRY_AMBIGUOUS(BodyConsumer, nsISupports,
                                       GlobalTeardownObserver)
  NS_INTERFACE_TABLE_END
NS_INTERFACE_TABLE_TAIL

}  // namespace mozilla::dom