Function main

02.18-coroutineParsingDataStream1/main.cpp:245–292

}

int main()
{
  std::vector<byte> fakeBytes1{0x70_B,
                               ESC,
                               SOF,
                               ESC,
                               'H'_B,
                               'e'_B,
                               'l'_B,
                               'l'_B,
                               'o'_B,
                               ESC,
                               SOF,
                               0x7_B,
                               ESC,
                               SOF};

  std::vector<byte> fakeBytes2{
    'W'_B, 'o'_B, 'r'_B, 'l'_B, 'd'_B, ESC, SOF, 0x99_B};

  auto stream1 = sender(std::move(fakeBytes1));

  DataStreamReader
       dr{};           // #A Create a DataStreamReader Awaitable
  auto p = Parse(dr);  // #B Create the Parse coroutine and pass
                       // the DataStreamReader

  for(const auto& b : stream1) {
    dr.set(b);  // #C Send the new byte to the waiting
                // DataStreamReader

    if(const auto& res = p(); res.length()) {
      HandleFrame(res);
    }
  }

  auto stream2 = sender(std::move(
    fakeBytes2));  // #D Simulate a second network stream

  for(const auto& b : stream2) {
    dr.set(b);  // #E We still use the former dr and p and feed
                // it with new bytes

    if(const auto& res = p(); res.length()) {
      HandleFrame(res);
    }
  }
}