risingwave_stream::common

Module rate_limit

Source

Functions§

limited_chunk_size 🔒
Get the rate-limited max chunk size.