  @Test
  public void singleTransactionShouldCloseConnection() throws Exception {

    Connection c = mock(Connection.class);
    ConnectionPool.of(c)
      .execute(connection -> just(null, null))
      .withSingleTransaction()
      .toBlocking().subscribe(o -> {}, throwable -> {});
    verify(c, times(1)).close();
  }