@GetSize
  public double getSize(
      @Element SubscriptionPartition subscriptionPartition,
      @Restriction OffsetByteRange restriction) {
    if (restriction.getRange().getTo() != Long.MAX_VALUE) {
      return restriction.getByteCount();
    }
    return newTracker(subscriptionPartition, restriction).getProgress().getWorkRemaining();
  }
@Test
  public void getProgressBoundedReturnsBytes() {
    assertTrue(
        DoubleMath.fuzzyEquals(
            123.0,
            sdf.getSize(PARTITION, OffsetByteRange.of(new OffsetRange(87, 8000), 123)),
            .0001));
    verifyNoInteractions(tracker);
  }