Function thr

example/spsc.cpp:121–127

Dummy thread blasting out values.

// Dummy thread blasting out values.
cobalt::thread thr(awaitable_spsc_queue<int> & q)
{
  for (int i = 0; i <= 100000000; i++)
    co_await q.write(i);

  co_await q.write(-1);
}

cobalt::main co_main(int argc, char * argv[])
{