src/main/java/com/github/ddth/cql/SessionManager.java
private FutureCallback<ResultSet> wrapCallbackRow(FutureCallback<Row> callback) {
        return new FutureCallback<ResultSet>() {
            @Override
            public void onSuccess(ResultSet result) {
                try {
                    callback.onSuccess(result.one());
                } finally {
                    asyncSemaphore.release();
                }
            }

            @Override
            public void onFailure(Throwable t) {
                try {
                    callback.onFailure(t);
                } finally {
                    asyncSemaphore.release();
                }
            }
        };
    }
private FutureCallback<ResultSet> wrapCallbackRow(FutureCallback<Row> callback) {
        return new FutureCallback<ResultSet>() {
            @Override
            public void onSuccess(ResultSet result) {
                try {
                    callback.onSuccess(result.one());
                } finally {
                    asyncSemaphore.release();
                }
            }

            @Override
            public void onFailure(Throwable t) {
                try {
                    callback.onFailure(t);
                } finally {
                    asyncSemaphore.release();
                }
            }
        };
    }
private FutureCallback < ResultSet > wrapCallbackRow ( FutureCallback < Row > callback ) { return new FutureCallback < ResultSet > ( ) { @ Override public void onSuccess ( ResultSet result ) { try { callback . onSuccess ( result . one ( ) ) ; } finally { asyncSemaphore . release ( ) ; } } @ Override public void onFailure ( Throwable t ) { try { callback . onFailure ( t ) ; } finally { asyncSemaphore . release ( ) ; } } } ; }
/*----------------------------------------------------------------------
/ * ----------------------------------------------------------------------