mirror of https://gitlab.torproject.org/tpo/core/arti http://git.dilluti0n.com/mirrors/arti.git/atom?h=arti-v1.4.6 2025-07-17T18:27:25Z 2025-07-17T18:27:25Z Steven Engler opara@torproject.org 2025-07-17T17:15:36Z urn:sha1:ad940e7327f6a64923fe4316500bfaaba26bafeb 2025-07-17T18:02:07Z Steven Engler opara@torproject.org 2025-07-17T07:19:38Z urn:sha1:66eec4843d37547c2e32e8f2e66fdadd999d8bff `DataReader` -> `DataReaderInner` `DataReaderNew` -> `DataReader` This means that the `DataReader` now supports XON/XOFF flow control using the `XonXoffReader`. This means that it can receive requests for a new drain rate from the reactor, and can send the new drain rate to the reactor once there is no more stream data queued. 2025-07-17T18:01:47Z Steven Engler opara@torproject.org 2025-07-17T05:47:08Z urn:sha1:ac0a34306105bb003573a854c64eedc9cefac51e The idea here is that the reactor builds an `XonXoffReaderCtrl` for the new stream, and the `XonXoffReaderCtrl` can receive notifications from the reactor's `StreamFlowControl`. The `XonXoffReaderCtrl` can be combined with any `AsyncRead` to build a `XonXoffReader`, essentially wrapping the `AsyncRead` with a type that handles XON/XOFF flow control. Essentially, the reactor gives you a type that allows you to add XON/XOFF flow control support to any `AsyncRead`. We will add this `XonXoffReader` to the `DataReader` in a future commit.