Resources.copy(ClassPathTest.class.getResource(entry), jarOut);
        jarOut.closeEntry();
      }
    } catch (Throwable e) {
      throw closer.rethrow(e);
    } finally {
      closer.close();
    }
  }

  private static Manifest manifest(String content) throws IOException {
    InputStream in = new ByteArrayInputStream(content.getBytes(US_ASCII));
    Manifest manifest = new Manifest();

    /** SMB2 tree disconnect command */
    protected static final short SMB2_TREE_DISCONNECT = 0x0004;
    /** SMB2 create/open file command */
    protected static final short SMB2_CREATE = 0x0005;
    /** SMB2 close file command */
    protected static final short SMB2_CLOSE = 0x0006;
    /** SMB2 flush file command */
    protected static final short SMB2_FLUSH = 0x0007;
    /** SMB2 read file command */

        // Create test index
        client.admin().indices().prepareCreate(TEST_INDEX).execute().actionGet();
    }

    @AfterClass
    public static void afterClass() throws Exception {
        runner.close();
        runner.clean();
    }

    @Before
    public void setUp() {
        // Setup for each test
    }

    @Test
    public void testPrivateConstructor() throws Exception {

        params.put("smb1Authentications", new SmbAuthentication[] { auth });
        client.setInitParameterMap(params);
        client.init();

        assertNotNull(client.smbAuthenticationHolder);

        client.close();

        assertNull(client.smbAuthenticationHolder);
    }

  }

  @Test
  fun file() {
    val file = File.createTempFile("RequestTest", "tmp")
    val writer = FileWriter(file)
    writer.write("abc")
    writer.close()
    val contentType = "text/plain".toMediaType()
    val body: RequestBody = file.asRequestBody(contentType)
    assertThat(body.contentType()).isEqualTo(contentType)
    assertThat(body.contentLength()).isEqualTo(3)

  } else {
    DCHECK_EQ(nullptr, session);
    return nullptr;
  }
}

void TF_CloseDeprecatedSession(TF_DeprecatedSession* s, TF_Status* status) {
  status->status = s->session->Close();
}

void TF_DeleteDeprecatedSession(TF_DeprecatedSession* s, TF_Status* status) {
  status->status = absl::OkStatus();
  if (s == nullptr) return;
  delete s->session;
  delete s;
}

pkg io, type Closer interface { Close }
pkg io, type Closer interface, Close() error
pkg io, type LimitedReader struct
pkg io, type LimitedReader struct, N int64
pkg io, type LimitedReader struct, R Reader
pkg io, type PipeReader struct
pkg io, type PipeWriter struct
pkg io, type ReadCloser interface { Close, Read }
pkg io, type ReadCloser interface, Close() error

  @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
  public void testRemovalNotification_clear_basher() throws InterruptedException {
    // If a clear() happens close to the end of computation, one of two things should happen:
    // - computation ends first: the removal listener is called, and the cache does not contain the
    //   key/value pair

	rows, err := DB.Select("name, count(*) as total").Table("users").Group("name").Having("name IN ?", []string{users[0].Name, users[1].Name}).Rows()
	if err != nil {
		t.Fatalf("got error %v", err)
	}

	defer rows.Close()
	for rows.Next() {
		var name string
		var total int64
		rows.Scan(&name, &total)

		if name == users[0].Name && total != 3 {
			t.Errorf("Should have one user having name %v", users[0].Name)

	buffer            []byte
	offset            int
	err               error
	debug             bool // Print details on failure. Add your own if more are needed.
}

func (cr *s3ChunkedReader) Close() (err error) {
	return nil
}

// Now, we read one chunk from the underlying reader.
// A chunk has the following format:
//