in src/Elastic.Channels/BufferedChannelBase.cs [229:239]
public override bool TryWrite(TEvent item)
{
if (InChannel.Writer.TryWrite(item))
{
Interlocked.Increment(ref _inflightEvents);
_callbacks.PublishToInboundChannelCallback?.Invoke();
return true;
}
_callbacks.PublishToInboundChannelFailureCallback?.Invoke();
return false;
}