class PubsubLiteUnboundedReader extends UnboundedReader<SequencedMessage> implements OffsetFinalizer {

  @Override
  public UnboundedSource<SequencedMessage, ?> getCurrentSource() {
    return source;
  }

  public  PubsubLiteUnboundedReader(
      UnboundedSource<SequencedMessage, ?> source, Map<Partition, SubscriberState> subscriberMap);

}