reactor-core/src/main/java/reactor/core/publisher/RingBuffer.java
@Override
	long getPending()
	{
		long consumed = RingBuffer.getMinimumSequence(gatingSequences, cursor.getAsLong());
		long produced = cursor.getAsLong();
		return produced - consumed;
	}
@Override
	long getPending()
	{
		long consumed = RingBuffer.getMinimumSequence(gatingSequences, cursor.getAsLong());
		long produced = cursor.getAsLong();
		return produced - consumed;
	}
See {@code RingBufferProducer.producerCapacity()}.