SyncFeedClient implements AutoCloseable { @Override public void close() { wrappedClient.close(); } SyncFeedClient(SessionParams params); SyncResult stream(List<SyncOperation> operations); @Override void close();  }
@Test public void testFeedJson() { SessionParams sessionParams = new SessionParams.Builder() .addCluster(new Cluster.Builder() .addEndpoint(Endpoint.create("localhost")) .build()) .setConnectionParams(new ConnectionParams.Builder() .setDryRun(true) .build()) .build(); SyncFeedClient feedClient = new SyncFeedClient(sessionParams); assertFeedSuccessful(feedClient); assertFeedSuccessful(feedClient); feedClient.close(); }