class GenericTransportBuffer implements TransportBuffer {

  @Override
  public void close() {
    try {
      os.flush();
    } catch (IOException e) {
      logger.warn("unable to flush os");
    }

    try {
      os.close();
    } catch (IOException e) {
      logger.warn("unable to close os");
    }
  }

  public  GenericTransportBuffer(long maxBatchSize, boolean useCompression,
      TransportSerializer serializer);

}