public virtual async Task WaitToWriteAsync()

in src/Elastic.Channels/BufferedChannelBase.cs [270:283]

• 12 lines of code
• 4 McCabe index (conditional complexity)

	public virtual async Task<bool> WaitToWriteAsync(TEvent item, CancellationToken ctx = default)
	{
		ctx = ctx == default ? TokenSource.Token : ctx;

		if (await WaitToWriteAsync(ctx).ConfigureAwait(false) && InChannel.Writer.TryWrite(item))
		{
			Interlocked.Increment(ref _inflightEvents);
			_callbacks.PublishToInboundChannelCallback?.Invoke();
			return true;
		}

		_callbacks.PublishToInboundChannelFailureCallback?.Invoke();
		return false;
	}