6 Commits

Author	SHA1	Message	Date
Christopher Kohlhoff	d6a4d3b898	Add interoperability between channels and associated_immediate_executor.	2023-03-08 21:05:44 +11:00
Christopher Kohlhoff	730441dcbb	Ensure buffered messages can still be received when channel is closed.	2023-03-06 23:37:39 +11:00
Christopher Kohlhoff	35e93e4e90	Update copyright notices.	2023-03-01 23:03:03 +11:00
Christopher Kohlhoff	68ef2b45d4	Add channel buffer specialisation for R(error_code).	2022-11-01 11:35:07 +11:00
Christopher Kohlhoff	ff58013a23	Update copyright notices.	2022-03-02 21:23:52 +11:00
Christopher Kohlhoff	495e6367af	Add experimental support for channels. ... This adds experimental::channel and experimental::concurrent_channel. Channels may be used to send completions as messages. For example: // Create a channel with no buffer space. channel<void(error_code, size_t)> ch(ctx); // The call to try_send fails as there is no buffer // space and no waiting receive operations. bool ok = ch.try_send(asio::error::eof, 123); assert(!ok); // The async_send operation blocks until a receive // operation consumes the message. ch.async_send(asio::error::eof, 123, [](error_code ec) { // ... }); // The async_receive consumes the message. Both the // async_send and async_receive operations complete // immediately. ch.async_receive( [](error_code ec, size_t n) { // ... });	2021-11-04 01:56:32 +11:00