These are chat archives for akkadotnet/AkkaStreams
ValueTask<bool> OfferAsync(T element)which returns
falseon dropped, while failure and queue closed should return a failed task (i.e. ObjectDisposedException on closed queue).
false? If it's back pressured,
Offershould just block.
.Wait()should block definitely, until queue is ready to get the element.