class BufferingPullSubscriber implements PullSubscriber {

  @Override
  public void close() {
    underlying.stopAsync().awaitTerminated();
  }

    BufferingPullSubscriber(SubscriberFactory factory, FlowControlSettings settings);
    BufferingPullSubscriber(
      SubscriberFactory factory, FlowControlSettings settings, Offset initialLocation);

}