Closed udsamani closed 1 week ago
[!IMPORTANT]
Review skipped
Auto reviews are disabled on this repository.
Please check the settings in the CodeRabbit UI or the
.coderabbit.yaml
file in this repository. To trigger a single review, invoke the@coderabbitai review
command.You can disable this status message by setting the
reviews.review_status
tofalse
in the CodeRabbit configuration file.
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
What are we doing here ?
cancel
function as part of stream. This cancel function is attached to the context which gets passed on to the engine, which serves the stream (currently only the log stream). If a heartbeat response is received from the consumer stating that it is no longer interested in this stream, then we invoke thiscancel
function. There might be scenarios where few logs will make it through after context cancelation due to race conditions. This should be fine and won't result innil
pointers or writing to a closed writer as we only close the writer after source channel is closed.