class BeamFnDataTimeBasedBufferingOutboundObserver extends BeamFnDataSizeBasedBufferingOutboundObserver<T> {

  @Override
  public void accept(T t) throws IOException {
    checkFlushThreadException();
    super.accept(t);
  }

    BeamFnDataTimeBasedBufferingOutboundObserver(
      int sizeLimit,
      long timeLimit,
      LogicalEndpoint outputLocation,
      Coder<T> coder,
      StreamObserver<BeamFnApi.Elements> outboundObserver);

}