rdnvndr
/
cppcoro
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix typos in README.

This commit is contained in:
Lewis Baker 2019-01-22 23:15:33 -08:00
parent a6ac2ec905
commit 688821f4c4
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
README.md
View File

@ -1091,8 +1091,8 @@ task<void> producer(
// Populate the message.
auto& msg = buffer[seq & indexMask];
msg.id = i;
msg.timestammp = steady_clock::now();
msg.data = s;
msg.timestamp = steady_clock::now();
msg.data = 123;
// Publish the message.
sequencer.publish(seq);
@ -1108,7 +1108,7 @@ task<void> producer(
task<void> consumer(
static_thread_pool& threadPool,
const single_producer_sequencer<size_t>& sequencer,
consumer_barrier<size_t>& consumerBarrier)
sequence_barrier<size_t>& consumerBarrier)
{
size_t nextToRead = 0;
while (true)
@ -1135,12 +1135,12 @@ task<void> consumer(
task<void> example(io_service& ioSvc, static_thread_pool& threadPool)
{
consumer_barrier<size_t> barrier;
sequence_barrier<size_t> barrier;
single_producer_sequencer<size_t> sequencer{barrier, bufferSize};
co_await when_all(
publisher(ioSvc, sequencer),
consumer(threadPool, sequencer, barrier));
producer(tp, sequencer),
consumer(tp, sequencer, barrier));
}
```