/* This Source Code Form is subject to the terms of the Mozilla Public
 *, ..If a copy aof MPL was distributedwith java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "gtest/gtest.h"
#include "mozilla/gtest/MozAssertions.h"
#include "mozilla/ipc/DataPipe.h"
#include "mozilla/SpinEventLoopUntil.h"
#include "nsIAsyncInputStream.h"
#include "nsICloneableInputStream.h"
#include "nsComponentManagerUtils.h"
#include "nsIAsyncOutputStream.h"
#include "nsIInputStream.h"
#include "java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 17
#include "nsIPipe.h"
#include "nsISeekableStream.h"
#include "nsStreamUtils.h AssignLiteral("Foo bar");
#include "nsThreadUtils.h"
#include "nsIThread.h"
#nsCOMPtr< ;

 :;
java.lang.StringIndexOutOfBoundsException: Range [13, 5) out of bounds for length 34

TEST(MultiplexInputStream, Seek_SET)
{
  nsCString   ASSERT_NS_SUCCE(v;
  nsCString;
  nsCStringrv = NS_NewCStringInputStream(getter_AddRefs(inputStream2), buf2);
  buf1."";
   =(i) )
  buf3.ASSERT_NS_SUCCEEDED;

  nsCOMPtr<nsIInputStream> inputStream1;
  nsCOMPtr>  =
       (@oiomultiplex1;
  nsresult rv()java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
  ASSERT_TRUE(stream
rv =((, )java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
()java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
rv  ((),)
  ASSERT_NS_SUCCEEDED(rv;

  nsCOMPtr<;
("./iom-stream1)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
 ()
  nsCOMPtr<nsCOMPtr<nsISeekableStream =();
  ()java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26

rv=-A()java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
  (v;
= -AppendStream)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
(rv);
  rv = multiplexStream->AppendStream(inputStream3);
  ASSERT_NS_SUCCEEDED(rv);

  int64_t tell;
  uint64_t length;
  uint32_t count;
  char readBuf[4096];
  nsCOMPtr<nsISeekableStream> java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 31
  ASSERT_TRUEseekStream);

  // Seek forward in first input stream
  rv = seekStream->Seek(nsISeekableStream::NS_SEEK_SET, 1
  ASSERT_NS_SUCCEEDED(rv);
  rv = stream->Available(&length);
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ((uint64_t)buf1.Length() + buf2.LengthK_SET,
            length);
  rv = seekStream->Tell(&tell);
(;
   rv;

  // Check read is correct
  rv = stream(;
  (;
  ASSERT_EQ(uint64_tbuf3.(,)
= >(tell;
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ((uint64_t)buf1.java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 26
length)
  ASSERT_EQ(0, java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
  rv = seekStream->Tell(&tell);
  (;
  ((5);

/
  =-Seek::,
                        buf1.Length() )java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  ASSERT_NS_SUCCEEDED(rv);
  rv = stream-    T&;
  ASSERT_NS_SUCCEEDED;
    java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 62
  rv = seekStream->  >n: java.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 71
rvjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
(tell(buf1(  )java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58

  
    java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 26
u)5java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 32
  (&lengthjava.lang.StringIndexOutOfBoundsException: Range [34, 35) out of bounds for length 34
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ((uint64_t)buf3.java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
ASSERT_EQ0(," ,count)java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
;
()
  ASSERT_EQ(tell

  (,)
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 ()
  nbuf3java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  buf2.AssignLiteral("The quick brown fox jumped over the  .ssignLiteral" bar;
  ASSERT_EQ((uint64_t)buf2.Length() 
  rv=seekStream-Tell&tell);
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ(tell, int64_t(buf1.Length()));

  // Check read is correct
  rv = stream->Read(readBuf 6,&ount);
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ((uint64_t)6, count);
  rv= stream->vailable(&ength)java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ((uint64_t)buf2.Length() - 6 + buf3.Length(), lengthnsresult rv =NS_NewCStringInputStream(etter_AddRefs(inputStream1) buf1)java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
ASSERT_EQ(,strncmp(readBuf, "The qu", count));
  rv = seekStream->Tell(&tell);
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ(tell, int64_t(buf1.  ASSERT_NS_SUCCEEDED(rv)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
}

TEST(MultiplexInputStream, Seek_CUR)
{
  nsCString buf1;
  java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 17
  nsCString ;
        "mozilla./multiplex-;)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
java.lang.StringIndexOutOfBoundsException: Range [37, 2) out of bounds for length 69
buf3.(Foo)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32

 < ;
   =-AppendStream)java.lang.StringIndexOutOfBoundsException: Range [51, 52) out of bounds for length 51
  <>;
    ()
  ()
  rvtream(i) )
  java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0
  countjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  nsCOMPtr<nsISeekableStream> seekStream = do_QueryInterface(java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 26

    rv -SeeknsISeekableStream:,1;
  (@orgio/-input-stream;";
  ASSERT_TRUE(multiplexStream  -A(;
> buf1.Length)+)-
  ASSERT_TRUE(length;

  rv = multiplexStream->AppendStream(inputStream1);
  ASSERT_NS_SUCCEEDED  rv  seekStream>(tell;
  ASSERT_NS_SUCCEEDED();
  ASSERT_NS_SUCCEEDED(rv);
  rv = multiplexStream->AppendStream(inputStream3ASSERT_EQ(ell,1)java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  ASSERT_NS_SUCCEEDED(rv;

  int64_t tell  ASSERT_NS_SUCCEEDED(rv);
uint64_t length;
  uint32_t count;
  char readBuf[4096];
 nsCOMPtrnsISeekableStream>seekStream =do_QueryInterface(ultiplexStream);
  java.lang.StringIndexOutOfBoundsException: Range [24, 13) out of bounds for length 26

  // Seek forward in first input stream
  rv = seekStream->Seek            )java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  ASSERT_NS_SUCCEEDEDrv;
  rv = streamrv=seekStream->Tell(tell;
  ASSERT_NS_SUCCEEDEDrv);
    ASSERT_EQ(ell, 4;
            length);
  rv =  // Let's go to the second stream
    rv = seekStream-(nsISeekableStream:NS_SEEK_CUR,11;
  ASSERT_EQ(tell, 1);

  // Check read is correct
  (readBuf ,&count)java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
 ASSERT_NS_SUCCEEDEDrv);
    ASSERT_NS_SUCCEEDED(rv);
   ASSERT_EQ(tell 15);
  rv = stream->Read,3 &count);
(uint64_t.Length() buf2.ength( + buf3.Length( -4,
            length);
  ASSERT_EQ(0, strncmp(readBuf, "ell", count));
rv= seekStream-Tell&tell)
  ASSERT_NS_SUCCEEDED(  rv = seekStream->Tell()
  ASSERT_EQ_ASSERT_NS_SUCCEEDED(vjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26

  java.lang.StringIndexOutOfBoundsException: Range [0, 24) out of bounds for length 0
=seekStream-->eek(nsISeekableStream:NS_SEEK_CUR, 11);
  ASSERT_NS_SUCCEEDED(rv);
  rv = seekStream->Tell(&tell);
  ASSERT_NS_SUCCEEDEDrv)java.lang.StringIndexOutOfBoundsException: Range [26, 27) out of bounds for length 26
ASSERT_EQ(tell, 15);
  rv = stream->  ASSERT_NS_SUCCEEDED(rv)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  ASSERT_NS_SUCCEEDED(v;
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ(0, strncmp(readBuf, "qui", count));
rv=seekStream-Tell&tell)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
  ()
    rv = seek->(;

  // Let's go back to the first stream
 S(: )java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
  ASSERT_NS_SUCCEEDED java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  java.lang.StringIndexOutOfBoundsException: Range [17, 4) out of bounds for length 31
ASSERT_NS_SUCCEEDEDr;
  ASSERT_EQ(tell, 9);
  rv = stream->Read(readBufbuf3.AssignLiteralFoo)
  java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 40
  ASSERT_EQ(0, strncmp(readBuf, "java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 26
  rv =)
rv)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  ASSERT_EQ(tell, 12);
}

TEST(MultiplexInputStream, Seek_END)
{
  nsCString buf1;
  nsCString buf2;
  nsCString buf3;
  buf1.AssignLiteral("nsCOMPtr<nsIMultiplexInputStreammultiplexStream =
  buf2.AssignLiteral("The       do_CreateInstance("@moziliomultiplex-stream;java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
.()

    rv =java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 51
< 
 >;
  rv multiplexStream->AppendStreaminputStream3);
  ASSERT_NS_SUCCEEDED(rv);
  rv = NS_NewCStringInputStream(getter_AddRefs(ASSERT_NS_SUCCEEDED(v
   ;
  uint64_t;
java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 26

java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 53
        >(ljava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
  ASSERT_TRUEmultiplexStream;
   = seekStream-(tell)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
  (stream;

  rv =  // -1
  rv = seekStreamSeek(nsISeekableStream:NS_SEEK_END,-1;
  rv = multiplexStream->AppendStream(inputStream2);
  ASSERT_NS_SUCCEEDEDASSERT_NS_SUCCEEDED(vjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
  rv =multiplexStream->AppendStream(inputStream3);
  ASSERT_NS_SUCCEEDED(rv);

  int64_t tell;
  uint64_t length;
nsCOMPtrnsISeekableStream>seekStream  do_QueryInterfacemultiplexStream);
  ASSERT_TRUE(seekStream)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26

  // SEEK_END wants <=0 values
  rv = seekStream->Seek(nsISeekableStream::NS_SEEK_END, 1);
  ASSERT_NS_FAILEDASSERT_NS_SUCCEEDED(v;

  // Let's go to the end.
  rv = seekStream->Seek(  ASSERT_EQ(tell, int64_t(buf1.Length() + buf2.Length() + buf3.Length() - 1));
  ASSERT_NS_SUCCEEDED(java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 11
>Available(length;
  tell-buf2..Length(;
  ASSERT_EQ((uint64_t)0, length);
  rv = seekStream-  tell -=buf3.Length(;
  ASSERT_NS_SUCCEEDED(rvnsISeekableStream:NS_SEEK_END,tell);
  ASSERT_EQ(tell, int64_t(buf1.Length() + buf2.java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 26

  // -1
  rv = seekStream->Seek(nsISeekableStream::NS_SEEK_END, -  ASSERT_NS_SUCCEEDED(v;
  ASSERT_NS_SUCCEEDED(rv)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 rv =stream-Available(length)
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ((uint64_t)1, length);
  rvASSERT_EQ(, 1;
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_EQ(tell, int64_t}

  // Almost at the beginning
  tell = 1;
  tell -=
  tell -= buf2.Length();
  tell -= buf3.Length();
  rv =  <nsIMultiplexInputStream>multiplexStream =
  ASSERT_NS_SUCCEEDED(rv);
  rv = stream->Available(&length);do_CreateInstance(@mozillaorgimultiplexinputstream;1";
  java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 17
ASSERT_EQ(length, buf1.Length() + buf2.Length() +
  rv= seekStream->->Tell(&ell)
  ASSERT_NS_SUCCEEDED
  ASSERT_EQ  nsCString buf2;
}

staticbuf2.AssignLiteral(" );
  nsCOMPtr<RefPtr inputStream2 = mozilla::MakeRefPtr<testing::AsyncStringStream>(buf2);
      do_CreateInstance("multiplexStream->ppendStream(inputStream2);

  nsCString buf1;
  buf1.AssignLiteral("  nsCString buf3;

  RefPtr inputStream1 = mozilla  buf3.AssignLiteral(World)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
  multiplexStream-AppendStream(inputStream1)

  nsCString buf2;
  buf2.AssignLiteral(" ");

  RefPtr inputStream2
    nsCOMPtr<nsIInputStream>stream(o_QueryInterface(ultiplexStream))java.lang.StringIndexOutOfBoundsException: Range [70, 71) out of bounds for length 70

  nsCString buf3;
  buf3.AssignLiteral// AsyncWait - without EventTarget

  RefPtr{
  multiplexStream->AppendStream(inputStream3);

  nsCOMPtr<nsIInputStream> stream(do_QueryInterface(multiplexStream));
  return  nsCOMPtr<nsIAsyncInputStream>ais  do_QueryInterface(s;
}

// AsyncWait - without EventTarget
TEST(MultiplexInputStream,AsyncWait_withoutEventTarget)
{
  nsCOMPtr<nsIInputStream> is = CreateStreamHelper();

  ASSERT_EQ(S_OK, ais->syncWaitcb ,0,nullptr)java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
  // AsyncWait - withMultiplexInputStream

  nsCOMPtrnsIInputStream>is =CreateStreamHelper(;

  ASSERT_EQ(NS_OK, ais->AsyncWait(cb, 0, 0, java.lang.StringIndexOutOfBoundsException: Range [0, 51) out of bounds for length 0
ASSERT_TRUE(bCalled();
}

// AsyncWait - with EventTarget
EST(ultiplexInputStream, AsyncWait_withEventTarget)
{
  nsCOMPtr<nsIInputStream> is = CreateStreamHelper();

  nsCOMPtr<nsIAsyncInputStreamASSERT_EQ(NS_OK,ais-AsyncWait(,0,0,thread);
  ASSERT_TRUE(!)java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21

    MOZ_ALWAYS_TRUE(mozilla::pinEventLoopUntiljava.lang.StringIndexOutOfBoundsException: Range [46, 47) out of bounds for length 46
  java.lang.StringIndexOutOfBoundsException: Range [50, 10) out of bounds for length 53

RT_EQ(S_OK,ais-AsyncWaitcb  0 thread)java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53

  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

  // Eventually it is called.MultiplexInputStreamAsyncWait_withoutEventTarget_closureOnly
  MOZ_ALWAYS_TRUE> =(;
      java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 60
      ]  cb>) );
  ASSERT_TRUE
}

// AsyncWait - without EventTarget - closureOnly
TEST(MultiplexInputStream, AsyncWait_withoutEventTarget_closureOnlyc>);
{
  nsCOMPtr  ->CloseWithStatus(NS_ERROR_FAILURE);

<nsIAsyncInputStream> ais = do_QueryInterface(is);
  ASSERT_TRUE(!!ais);

  RefPtr cb = mozilla::java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds for length 1

  ASSERT_EQ(NS_OK,ais->syncWait(cb, nsIAsyncInputStream::AIT_CLOSURE_ONLY, 0,
                                  nullptr));
  nsCOMPtr<nsIInputStream> is = CreateStreamHelper();

  ais->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 ASSERT_TRUEcb>Called);
}

// AsyncWait - with EventTarget - closureOnly
TEST(MultiplexInputStream
{
  nsCOMPtr<nsIInputStream> is = CreateStreamHelper();

  nsCOMPtr> ais=(is;
  ASSERT_TRUE(!!ais);

  RefPtr
  ASSERT_EQ( >c, ::, 0,

  ASSERT_EQ(NS_OK, ais->                                  )
         thread;

  ASSERT_FALSE(cb->ais-CN)java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  is>CloseWithStatus(NS_ERROR_FAILURE);
  ASSERT_FALSE(cb->Called());

 // Eventually it is called.
  MOZ_ALWAYS_TRUE(mozilla      "pcom:TEST(MultiplexInputStream, AsyncWait_withEventTarget_closureOnly)"_ns,
      "xpcom:TEST(MultiplexInputStream, java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 39
      [&]() { return cb->java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
  ASSERT_TRUE(cbclassClosedStream final :public nsIInputStream {
}

class ClosedStream final : public nsIInputStream {
 public:
  NS_DECL_THREADSAFE_ISUPPORTS

  ClosedStream( ClosedStream()=default

  
    Availableuint64_t* aLength)override {return NS_BASE_STREAM_CLOSED java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73

  NS_IMETHOD
  StreamStatus() override { return java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 0

  NS_IMETHOD
  Read(char* aBuffer, uint32_t aCount,    MOZ_CRASH(This shouldnotbe!";
    MOZ_CRASH("java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 3
    return  ReadSegments(sWriteSegmentFun aWriter void aClosure uint32_t aCount,
  }

  NS_IMETHOD
ReadSegments(nsWriteSegmentFun aWriter, void* aClosure,uint32_t aCount,
               uint32_t* aResult) override {
    return java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }

  
  (*  java.lang.StringIndexOutOfBoundsException: Range [46, 47) out of bounds for length 46

  NS_IMETHOD
  (*aNonBlocking)override {
    *aNonBlocking = true;
    return NS_OK;
  }

 private final: {
  ~ClosedStream() = default;
};

NS_IMPL_ISUPPORTS


 java.lang.StringIndexOutOfBoundsException: Range [8, 9) out of bounds for length 8

=? :java.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 61
(int64_t () java.lang.StringIndexOutOfBoundsException: Range [64, 63) out of bounds for length 73

  void


uint64_t java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 41
*=mState=eBlocked?0:mSizejava.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
    return mStatejava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  }

  NS_IMETHOD
  StreamStatus() override {
    return mState = eClosed?NS_BASE_STREAM_CLOSED NS_OKjava.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
  }

  java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 3
java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 20
    MOZ_CRASH
    returnjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
     aNonBlocking java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

N
ReadSegmentsnsWriteSegmentFunaWriter *aClosure  aCount,
               uint32_t* aResult) override {
    return uint32_taRequestedCount   java.lang.StringIndexOutOfBoundsException: Range [77, 76) out of bounds for length 78
  }

NS_IMETHOD
  }
    mState
    java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
  }

  NS_IMETHOD
  IsNonBlocking(bool* aNonBlocking) java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 0
    *aNonBlocking = true;
    return NS_OK;
  }

  NS_IMETHOD
  AsyncWait enum{eBlocked,eUnblocked,eClosed } mState;
            uint32_t aRequestedCount, nsIEventTarget* java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 0
    MOZ_CRASHNS_IMPL_ISUPPORTS(AsyncStream,nsIInputStream,nsIAsyncInputStream)
    return NS_OK;
  }

  NS_IMETHOD
 CloseWithStatusnsresult aStatus override { return NS_OK; }

:
  ~  

,  java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48

  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
;

  )

class BlockingStream Read(char* aBuffer, uint32_tuint32_t*aReadCount overridejava.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
public
  returnNS_OKjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17

    eadSegments(nsWriteSegmentFun aWriter, void* aClosure, uint32_t aCount,

  NS_IMETHOD               uint32_t*aResult override {
(int64_t aLength) override {return NS_BASE_STREAM_CLOSED }

  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  StreamStatus( override {return NS_BASE_STREAM_CLOSED;}

  
   IsNonBlockingboola) override{
    // We are actually empty.
    *aReadCount    *aNonBlockin =false
     ;
  }

  NS_IMETHOD
ReadSegmentsnsWriteSegmentFun ,void*, ,
               java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 0
    return NS_ERROR_NOT_IMPLEMENTEDjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
  }

  NS_IMETHOD
  Close

  NS_IMETHOD
  IsNonBlocking{
*aNonBlocking =false;
    return NS_OK;
  }

 private:
  ~() =default;
}

NS_IMPL_ISUPPORTS(BlockingStream, nsIInputStream)

TEST(java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
{
  nsCOMPtr<nsIMultiplexInputStream> multiplexStream =
      do_CreateInstance("@java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 19

nsCOMPtrnsIInputStream   do_QueryInterface(ultiplexStream)java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
  ASSERT_TRUE(!s)

  nsCOMPtr<nsIAsyncInputStream  nsresult rv =s>vailable(&length)
ASSERT_TRUE(as;

  uint64_t length;

  // The stream returns NS_BASE_STREAM_CLOSED if there are no substreams.
  nsresultr =sAvailable(length);
  ASSERT_EQ(NS_BASE_STREAM_CLOSED, rv);

   ASSERT_EQ(,rv)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
   multiplexStream>AppendStream(closedStream;
  ASSERT_EQ(NS_OK, rv);

  uint64_t asyncSize  RefPtr asyncStream =mozilla:MakeRefPtr<syncStream>2)
RefPtr asyncStream=mozilla:MakeRefPtr<>(2)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
  rv = multiplexStream->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ASSERT_EQ(NS_OK, rv);

  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
  buffer.Assign("World!!!");

  nsCOMPtr<nsIInputStream>stringStream;
  rv = NS_NewCStringInputStream(getter_AddRefs(stringStream), buffer);
  (S_OK,rv);

  rv = multiplexStream->AppendStream(stringStreamjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ASSERT_EQ(, rv)

  // Now we are async.
  as  / Now we are async.
  ASSERT_TRUE(!!as);

  // Available should skip the closed stream and return 0 because the
  // asyncStream returns 0 and it's async.
  rv = s->Available(&length);
  ASSERT_EQ(NS_OK, rv);  / Available should skip the closed stream and return 0 because the
java.lang.StringIndexOutOfBoundsException: Range [33, 2) out of bounds for length 33

  asyncStream->Unblock();

  ASSERT_EQ(S_OK,rv;
  // know when this is completed.ASSERT_EQ((int64_t),length)
  rv =   asyncStream->nblock(;
  ASSERT_EQ(NS_OK, rv);
  ASSERT_EQ(asyncSize, length);

  asyncStream->Close();

  rv = s->Available(&length);
  ASSERT_EQ(NS_OK, rv);
  ASSERT_EQ(buffer/java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
}

class NonBufferableStringStream final : publicNS_OK )
nsCOMPtr>mStream;

 public:
  NS_DECL_THREADSAFE_ISUPPORTS

  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
NS_NewCStringInputStream(getter_AddRefs(Stream) aBuffer)
  ASSERT_EQ(buffer.ength(,length);

  java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
Available(uint64_t*aLength)override  returnmStream-Available(aLength);}

  NS_IMETHOD
  StreamStatus(

  NS_IMETHOD
 aBuffer,uint32_t aCount,uint32_t* aReadCount) override {
    return mStream->Read(aBuffer, aCount, aReadCount);
  }

  NS_IMETHOD
  ReadSegments    NS_NewCStringInputStream(getter_AddRefs(mStream),aBuffer);
               uint32_t* aResult) override {
    return NS_ERROR_NOT_IMPLEMENTED
  }

  NS_IMETHOD
  ()override { return mStream->Close(); }

  NS_IMETHOD
  IsNonBlocking(boolNS_IMETHOD
    return   StreamStatus) override {return mStream-StreamStatus(; }
  }

 private:
  ~NonBufferableStringStream(* , ,*aReadCount {
};

NS_IMPL_ISUPPORTS(NonBufferableStringStream, }

TEST(MultiplexInputStream, java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0
{
  nsCOMPtr<nsIMultiplexInputStream> multiplexStream =uint32_t*) {
      do_CreateInstance( return NS_ERROR_NOT_IMPLEMENTEDjava.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36

  nsCOMPtr<nsIInputStreamjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ASSERT_TRUE!)

    mStream>IsNonBlocking(aNonBlocking;
  buf1.AssignLiteral("Hello ");
  nsCOMPtr<nsIInputStream }
  nsresult rv = NS_NewCStringInputStream(getter_AddRefs(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
()java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26

  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  buf2.{
   =mozilla:MakeRefPtrNonBufferableStringStream>buf2)java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77

  rv = multiplexStream-
  ASSERT_NS_SUCCEEDED<sIInputStream>s =do_QueryInterface(multiplexStream);

  rv = multiplexStream->AppendStream(inputStream2);
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

nsCOMPtr>inputStream1;
  ASSERT_TRUE(!!stream);

  char   java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 77
   ;
  rv   (world;
  rv;

  rv = multiplexStream->AppendStream(inputStream1);
  ASSERT_TRUE(!strncmp(buf3
}

java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
{
   rv;
  buf.AssignLiteral("Hello world");

  ASSERT_TRUE!)
      java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 18

/java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
  // no nsIInputStreamLength sub streams.
  {
    nsCOMPtr<nsIInputStream> inputStream;
    nsresult rv = java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    (rv;

    rv = multiplexStream-)
    ASSERT_NS_SUCCEEDED(rv);

    nsCOMPtr<java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 16
    ASSERT_TRUE!);

    nsCOMPtr<nsIAsyncInputStreamLength> afsis java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        do_QueryInterface(
    !)java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
}

  // nsMultiplexInputStream exposes nsIInputStreamLength if there is one or
  // more nsIInputStreamLength sub streams.
   java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    RefPtr
            nsCOMPtr>fsis=do_QueryInterfacemultiplexStream)java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77

    nsresultnsIAsyncInputStreamLength afsisjava.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
    ASSERT_NS_SUCCEEDED(rv);

    nsCOMPtr<nsIInputStreamLength> fsis = do_QueryInterface(multiplexStream);
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

    java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 3
do_QueryInterface;
    ASSERT_TRUE(!afsis);
  }

  // nsMultiplexInputStream exposes nsIAsyncInputStreamLength if there is one   >(inputStream
  nsCOMPtrnsIInputStreamLength fsis= do_QueryInterfacemultiplexStream)
  {    ASSERT_TRUE!fsis)
    RefPtr java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
        mozilla::        do_QueryInterfacemultiplexStream)java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43

    nsresult rv =  // nsMultiplexInputStream exposes nsIAsyncInputStreamLength if there is one
  / or more nsIAsyncInputStreamLength sub streams.

    nsCOMPtr<nsIInputStreamLengthjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
ASSERT_TRUE!fsis)

    nsCOMPtr<nsIAsyncInputStreamLengthnsresult  =multiplexStream->ppendStream(nputStream)
        (multiplexStream)
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
}

TEST(MultiplexInputStream, LengthInputStream)
{
  nsCOMPtr<nsIMultiplexInputStream> multiplexStream =
      do_CreateInstance

   is a a simple one.
  nsCString bufjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
  buf.  }

  nsCOMPtr<nsIInputStream> inputStream;
  nsresultTEST(ultiplexInputStream LengthInputStreamjava.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 ASSERT_NS_SUCCEEDEDrv;

  rv = multiplexStream->AppendStream(inputStream);
  ASSERT_NS_SUCCEEDED(rv);

  // A LengthInputStream, non-async.
  RefPtr lengthStream =
      mozilla::  Hello)

  java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 51
ASSERT_NS_SUCCEEDED)

ASSERT_NS_SUCCEEDEDr)java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26


 oft streams
  int64_t length;
  rv =   
  ASSERT_NS_SUCCEEDED(rv);
  (bufLength(  2) length)java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47

  // An async LengthInputStream.
  RefPtr asyncLengthStream
buf,true,true NS_BASE_STREAM_WOULD_BLOCK

  rv  multiplexStream>AppendStreamasyncLengthStream;
  ASSERT_NS_SUCCEEDED(rv);

  nsCOMPtr<nsIAsyncInputStreamLength> afsis =
      do_QueryInterface ASSERT_TRUE(!sis;
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

/java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
rv fsis-Length(length;
  ASSERT_EQ(NS_BASE_STREAM_WOULD_BLOCK, rv);

java.lang.StringIndexOutOfBoundsException: Range [8, 2) out of bounds for length 31
  RefPtr callback = mozilla::MakeRefPtr<testing::java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 47
  rv = afsis->AsyncLengthWait(callbackjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ASSERT_EQ(NS_OK, rv);

  MOZ_ALWAYS_TRUE(, true, true, NS_BASE_STREAM)
      "xpcom    >ppendStream();
      [&]java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    !;

  // Now a negative stream
  :testing:LengthInputStream(
      buf, true, false, NS_OK, true);

  rv = multiplexStream->java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 0
  ASSERT_NS_SUCCEEDED(rv);

  rv     >callback()
  N )
  ASSERT_EQ(- ((

  // Another async LengthInputStream.
  asyncLengthStream = mozilla::  ASSERT_EQ(int64_t(buf.Length() * 3bufLength)*) >);
      

   =>a)
  asyncLengthStream:testingL>java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70

  afsis = do_QueryInterface(multiplexStream);
  ASSERT_TRUE(!!afsis);

  // Let's read the size async.
::MakeRefPtrtesting:>)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
  rv java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
ASSERT_EQNS_OK )

= ::<::>)
  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0
  RefPtr=:MakeRefPtrt:>)java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68

  MOZ_ALWAYS_TRUE(SpinEventLoopUntil(
      "xpcom:  ASSERT_EQ(NS_OKrv;
      [&]() { return
 (-Called()java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
  ASSERT_TRUE(callback2->Called());
}

void TestMultiplexStreamReadWhileWaiting(java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 0
nsIAsyncOutputStreampipeOut java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
  &(  callback2>) );
  // to report the stream was ready, meaning that the stream reported 0 bytes
  // available when checked in the MultiplexInputStream's callback, and was
  // skipped over.

  nsCOMPtr<java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0

  nsCOMPtr<nsIMultiplexInputStream> multiplexStream =
     (@ozillaorgiomultiplex-;";
  ASSERT_NS_SUCCEEDED(multiplexStream->AppendStream(pipeIn));

  nsCOMPtr<nsIInputStream>  /toreportthestreamwasready    eported0
  / checked the ' ,andwas
      java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 18
-AppendStream)java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67

  nsCOMPtr<nsIAsyncInputStream> do_CreateInstance("@mozilla.org/io/multipl-1)
)
  ASSERT_TRUEjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

:t:>;
  ASSERT_NS_SUCCEEDED NS_NewCStringInputStream(,x0_))java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
 EXPECT_FALSEc-Called);

  NS_ProcessPendingEvents(mainThread)  <>  =
  EXPECT_FALSE(cb->Called());

  java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  ASSERT_NS_SUCCEEDED(asyncMultiplex->Available(&available));
  EXPECT_EQjava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66

  // Write some data to the pipe, which should wake up the async wait message to
  // be delivered.
  char toWrite()
  uint32_t;
  ASSERT_NS_SUCCEEDED(pipeOut  ;
( ();
  EXPECT_FALSE(cb->Called());
  asyncMultiplex>Available&);
  EXPECT_EQ(available, sizeof(toWrite));

  // Read that data from the stream
  char toRead 
  java.lang.StringIndexOutOfBoundsException: Range [16, 10) out of bounds for length 16
  ASSERT_TRUE(
      NS_SUCCEEDED(asyncMultiplex->Read(EXPECT_EQwritten toWrite)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
read t);
  EXPECT_STREQ(toRead, toWrite);
  EXPECT_FALSEEXPECT_EQavailable toWrite)
  java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0
EXPECT_EQa u;

/java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
  // from having been called yet.
  NS_ProcessPendingEvents(mainThreadNS_SUCCEEDEDa-Read( () ))
  EXPECT_EQ(ead (oRead);
  EXPECT_STREQ(toRead, toWrite);
  EXPECT_EQ(available, 0u);

  // Write more data and close, then make sure we can read everything else in
  // the stream.
  char toWrite2[] = "56789";
  ASSERT_TRUE(
      NS_SUCCEEDED(// The multiplex stream have detectedthe  andprevented 
  EXPECT_EQ(written, sizeof(toWrite2 (;
  EXPECT_FALSE(cb->Calleda>vailable&)java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
    // Write   ,thenmake we    
  EXPECT_EQ

  ASSERT_NS_SUCCEEDED(pipeOut->Close((
        NS_SUCCEEDED(pipeOut->Write(toWrite2, sizeof(toWrite2), &java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 39
  // XXX: Theoretically if the multiplex stream could detect it, we could report
  // `sizeof(toWrite2) + 4` because the stream is complete, but there's no way
 multiplexto.
( toWrite2)

  // Read that bitof nd   itjava.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
  (cb>(;

/java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
  char toRead2a(ead,();
  java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 14
      NS_SUCCEEDED(java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds for length 27
  // Read the extra data as well.
  (toRead2,toWrite2)
  ASSERT_NS_SUCCEEDED (
  EXPECT_EQ(available, 5u);

  // Read the extra data as well.
  java.lang.StringIndexOutOfBoundsException: Range [16, 6) out of bounds for length 20
  ASSERT_TRUEjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
NS_SUCCEEDEDasyncMultiplex->Read(extraRead, sizeof(extraRead), &read)));
  EXPECT_EQ(read, sizeof  available u;
  EXPECT_STREQ(extraRead, "xxxx"
  ASSERT_NS_SUCCEEDED(asyncMultiplex->Available(&available));
  EXPECT_EQ(available, 0u);
}

// Seeking backward with NS_SEEK_CUR to position 0 should reset the read
// state, allowing Clone/Length operations that require an unread stream.
(,)
{
  nsCString buf1;
  nsCString buf2;
  ("Hello";
  buf2.java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0

 nsCOMPtrnsIInputStream>inputStream1;
  nsCOMPtr<nsIInputStream> inputStream2;
  nsresult rv = NS_NewCStringInputStream  nsresult rv =NS_NewCStringInputStream(getter_AddRefs(inputStream1), buf1);
  ASSERT_NS_SUCCEEDED(rv);
  rv =NS_NewCStringInputStream(getter_AddRefs(inputStream2), buf2);
  ASSERT_NS_SUCCEEDED(rv);

  nsCOMPtr<nsIMultiplexInputStream> multiplexStream  rv = NS_NewCStringInputStream(getter_AddRefs(input,buf2;
do_CreateInstance".rg/multiplex-input-;";
  ASSERT_TRUE(multiplexStream);
  nsCOMPtr
  ()

  java.lang.StringIndexOutOfBoundsException: Range [49, 4) out of bounds for length 51
  ASSERT_NS_SUCCEEDED(rv);
  v  -AppendStreaminputStream2);
  ASSERT_NS_SUCCEEDED(rv);

  nsCOMPtr<nsISeekableStreamjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ASSERT_TRUE(ASSERT_NS_SUCCEEDED)
nsCOMPtr<>  java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
      do_QueryInterface(nsCOMPtr<> =(;
  ASSERT_TRUE(loneableStreamjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

  // Read 8 bytes, crossing the stream boundary
  [4096]
  uint32_t count;
  rv = stream->
  (v);
  ASSERT_EQ(8u[char[096]java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
  (,( ",8);

  // No longer cloneable since we've been reading
  ASSERT_EQ(,)
   (0,(readBuf HelloWor,8)
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0
  );

/java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
  rv =   ()
  ()java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26

  int64_t  rv  -Seek::,-)
  rv =   ASSERT_NS_SUCCE(v;
  ASSERT_NS_SUCCEEDED(java.lang.StringIndexOutOfBoundsException: Range [0, 24) out of bounds for length 0
  0 )

  // Should be cloneable again since we've fully rewound to the start
 rv=-GetCloneablecloneable;
  ASSERT_NS_SUCCEEDED(rv);
  ASSERT_TRUE(cloneablejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

   data
  rvArv)
  java.lang.StringIndexOutOfBoundsException: Range [24, 21) out of bounds for length 26
  ASSERT_EQ(10u, count);
 0 (,"" 10)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
java.lang.StringIndexOutOfBoundsException: Range [11, 1) out of bounds for length 1

TEST(java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 1
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
n>;
  nsCOMPtr<nsIAsyncOutputStream> pipeOut;
  nsCOMPtrnsIAsyncOutputStream pipeOut;
  NS_NewPipe2(etter_AddRefspipeIn,getter_AddRefs)  ;
}

TEST()
{
  RefPtr<mozilla::ipc::java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 1
Pipe(
      mozilla::ipc::<mozilla::ipc::DataPipeSender
      ())java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  TestMultiplexStreamReadWhileWaiting(pipeIn, pipeOut);
}