@@ -0,0 +1,1567 @@
+package io.vertx.cassandra.streaming;%0A%0Aimport io.vertx.cassandra.CassandraClient;%0Aimport io.vertx.cassandra.CassandraClientOptions;%0Aimport io.vertx.cassandra.CassandraRowStream;%0Aimport io.vertx.core.AbstractVerticle;%0Aimport io.vertx.core.Launcher;%0A%0Apublic class StreamingExample extends AbstractVerticle %7B%0A%0A%0A  /**%0A   * Convenience method so you can run it in your IDE%0A   */%0A  public static void main(String%5B%5D args) %7B%0A    Launcher.main(new String%5B%5D%7B%22run%22, StreamingExample.class.getName()%7D);%0A  %7D%0A%0A  @Override%0A  public void start() %7B%0A    CassandraClient client = CassandraClient.createNonShared(vertx, new CassandraClientOptions().setPort(9042));%0A    client.queryStream(%22SELECT * from system_schema.tables  WHERE keyspace_name = 'system_schema' %22, cassandraRowStreamAsyncResult -%3E %7B%0A      if (cassandraRowStreamAsyncResult.succeeded()) %7B%0A        System.out.println(%22Tables in system_schema: %22);%0A        CassandraRowStream stream = cassandraRowStreamAsyncResult.result();%0A        stream%0A          .endHandler(end -%3E %7B%0A            System.out.println(%22%3CEnd of Cassandra row stream%3E%22);%0A          %7D)%0A          .handler(row -%3E %7B%0A            String systemSchema = row.getString(%22table_name%22);%0A            System.out.println(%22%5Ct%22 + systemSchema);%0A          %7D)%0A          .exceptionHandler(throwable -%3E %7B%0A            System.out.println(%22An exception occurred:%22);%0A            throwable.printStackTrace();%0A          %7D);%0A      %7D else %7B%0A        System.out.println(%22Unable to execute the query%22);%0A        cassandraRowStreamAsyncResult.cause().printStackTrace();%0A      %7D%0A    %7D);%0A  %7D%0A%7D%0A

add Streaming example