Add `Sender::force_send`

Open BTOdell opened this issue 1 year ago • 2 comments

Closes #142

I haven't added any tests yet because I didn't know which test files to add them to. I'd like to just add a couple smoke tests.

Mar 16 '24 08:03 BTOdell

Hi, thanks for the PR! I'll try to find time to review this in the next few days.

One thing I would say is that there are some invariants to maintain here: in particular, send_timeout expects to be able to pull the old value back out of the queue afterwards, so care will need to be taken to not accidentally violate this.

Mar 18 '24 07:03 zesterer

Hi there! I came across the discussion and found that we implemented the lossy channel in a similar way. It would be nice if flume officially support this feature. Is there any reason this PR is being blocked or anything needs help?

Jul 04 '24 17:07 YuanYuYuan