@@ -0,0 +1,1301 @@
+package org.influxdb.impl;%0A%0Aimport static org.junit.jupiter.api.Assertions.assertFalse;%0Aimport static org.junit.jupiter.api.Assertions.assertTrue;%0A%0Aimport java.lang.reflect.Field;%0A%0Aimport org.influxdb.InfluxDB;%0Aimport org.influxdb.TestUtils;%0Aimport org.junit.jupiter.api.AfterEach;%0Aimport org.junit.jupiter.api.BeforeEach;%0Aimport org.junit.jupiter.api.Test;%0A%0Aimport okhttp3.OkHttpClient;%0A%0Apublic class InfluxDBImplTest %7B%0A%0A  private InfluxDB influxDB;%0A%0A  @BeforeEach%0A  public void setUp() throws Exception %7B%0A    this.influxDB = TestUtils.connectToInfluxDB();%0A  %7D%0A  %0A  @AfterEach%0A  public void cleanup() %7B%0A    influxDB.close();%0A  %7D%0A%0A  @Test%0A  public void closeOkHttpClient() throws Exception %7B %0A    OkHttpClient client = getPrivateField(influxDB, %22client%22);%0A    assertFalse(client.dispatcher().executorService().isShutdown());%0A    assertFalse(client.connectionPool().connectionCount() == 0);%0A    influxDB.close();%0A    assertTrue(client.dispatcher().executorService().isShutdown());%0A    assertTrue(client.connectionPool().connectionCount() == 0);%0A  %7D%0A%0A  @SuppressWarnings(%22unchecked%22)%0A  static %3CT%3E T getPrivateField(final Object obj, final String name)%0A      throws Exception %7B%0A    Field field = obj.getClass().getDeclaredField(name);%0A    field.setAccessible(true);%0A    return (T) field.get(obj);%0A  %7D%0A%0A%7D%0A

Add test case