PubsubLiteUnboundedReader extends UnboundedReader<SequencedMessage> implements OffsetFinalizer { @Override public UnboundedSource<SequencedMessage, ?> getCurrentSource() { return source; } PubsubLiteUnboundedReader(
      UnboundedSource<SequencedMessage, ?> source, Map<Partition, SubscriberState> subscriberMap); @Override void finalizeOffsets(Map<Partition, Offset> offsets); @Override boolean start(); @Override boolean advance(); @Override SequencedMessage getCurrent(); @Override Instant getCurrentTimestamp(); @Override void close(); @Override Instant getWatermark(); @Override CheckpointMark getCheckpointMark(); @Override UnboundedSource<SequencedMessage, ?> getCurrentSource();  }
@Test public void sourceReturnsSource() { assertThat(reader.getCurrentSource(), sameInstance(source)); }