Restore the RX Java 1 Example.

Author: cescoffier

rx-examples/src/main/java/io/vertx/example/rxjava/database/jdbc/Client.java

@@ -0,0 +1,47 @@
+package io.vertx.example.rxjava.database.jdbc;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.example.util.Runner;
+import io.vertx.ext.sql.ResultSet;
+import io.vertx.rxjava.core.AbstractVerticle;
+import io.vertx.rxjava.ext.jdbc.JDBCClient;
+import rx.Single;
+
+/*
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public class Client extends AbstractVerticle {
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runExample(Client.class);
+  }
+
+  @Override
+  public void start() throws Exception {
+
+    JsonObject config = new JsonObject().put("url", "jdbc:hsqldb:mem:test?shutdown=true")
+      .put("driver_class", "org.hsqldb.jdbcDriver");
+
+    JDBCClient jdbc = JDBCClient.createShared(vertx, config);
+
+    // Connect to the database
+    jdbc.rxGetConnection().flatMap(conn -> {
+
+      // Now chain some statements using flatmap composition
+      Single<ResultSet> resa = conn.rxUpdate("CREATE TABLE test(col VARCHAR(20))")
+        .flatMap(result -> conn.rxUpdate("INSERT INTO test (col) VALUES ('val1')"))
+        .flatMap(result -> conn.rxUpdate("INSERT INTO test (col) VALUES ('val2')"))
+        .flatMap(result -> conn.rxQuery("SELECT * FROM test"));
+
+      return resa.doAfterTerminate(conn::close);
+
+    }).subscribe(resultSet -> {
+      // Subscribe to the final result
+      System.out.println("Results : " + resultSet.getRows());
+    }, err -> {
+      System.out.println("Database problem");
+      err.printStackTrace();
+    });
+  }
+}

rx-examples/src/main/java/io/vertx/example/rxjava/database/jdbc/Streaming.java

@@ -0,0 +1,39 @@
+package io.vertx.example.rxjava.database.jdbc;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.example.util.Runner;
+import io.vertx.rxjava.core.AbstractVerticle;
+import io.vertx.rxjava.ext.jdbc.JDBCClient;
+
+/*
+ * @author <a href="mailto:[email protected]">Paulo Lopes</a>
+ */
+public class Streaming extends AbstractVerticle {
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runExample(Streaming.class);
+  }
+
+  @Override
+  public void start() throws Exception {
+
+    JsonObject config = new JsonObject().put("url", "jdbc:hsqldb:mem:test?shutdown=true")
+      .put("driver_class", "org.hsqldb.jdbcDriver");
+
+    JDBCClient jdbc = JDBCClient.createShared(vertx, config);
+
+    jdbc
+      .rxGetConnection() // Connect to the database
+      .flatMapObservable(conn -> { // With the connection...
+        return conn.rxUpdate("CREATE TABLE test(col VARCHAR(20))") // ...create test table
+          .flatMap(result -> conn.rxUpdate("INSERT INTO test (col) VALUES ('val1')")) // ...insert a row
+          .flatMap(result -> conn.rxUpdate("INSERT INTO test (col) VALUES ('val2')")) // ...another one
+          .flatMap(result -> conn.rxQueryStream("SELECT * FROM test")) // ...get values stream
+          .flatMapObservable(sqlRowStream -> {
+            return sqlRowStream.toObservable() // Transform the stream into an Observable...
+              .doOnTerminate(conn::close); // ...and close the connection when the stream is fully read or an error occurs
+          });
+      }).subscribe(row -> System.out.println("Row : " + row.encode()));
+  }
+}

rx-examples/src/main/java/io/vertx/example/rxjava/database/mongo/Client.java

@@ -0,0 +1,67 @@
+package io.vertx.example.rxjava.database.mongo;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.example.util.Runner;
+import io.vertx.rxjava.core.AbstractVerticle;
+import io.vertx.rxjava.ext.mongo.MongoClient;
+import rx.Observable;
+
+/*
+ * @author <a href="mailto:[email protected]">Julien Viet</a>
+ */
+public class Client extends AbstractVerticle {
+
+  private MongoClient mongo;
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runExample(Client.class);
+  }
+
+  @Override
+  public void start() throws Exception {
+
+    JsonObject config = new JsonObject()
+        .put("connection_string", "mongodb://localhost:27018")
+        .put("db_name", "my_DB");
+
+    // Deploy an embedded mongo database so we can test against that
+    vertx.deployVerticle("service:io.vertx.vertx-mongo-embedded-db", db -> {
+      if (db.succeeded()) {
+
+        // Create the client
+        mongo = MongoClient.createShared(vertx, config);
+
+        insertAndFind();
+
+      } else {
+        System.out.println("Could not start mongo embedded");
+        db.cause().printStackTrace();
+      }
+    });
+  }
+
+  private void insertAndFind() {
+    // Documents to insert
+    Observable<JsonObject> documents = Observable.just(
+      new JsonObject().put("username", "temporalfox").put("firstname", "Julien").put("password", "bilto"),
+      new JsonObject().put("username", "purplefox").put("firstname", "Tim").put("password", "wibble")
+    );
+
+    mongo.rxCreateCollection("users").flatMapObservable(v -> {
+      // After collection is created we insert each document
+      return documents.flatMap(doc -> mongo.rxInsert("users", doc).toObservable());
+    }).doOnNext(id -> {
+      System.out.println("Inserted document " + id);
+    }).last().toSingle().flatMap(id -> {
+      // Everything has been inserted now we can query mongo
+      System.out.println("Insertions done");
+      return mongo.rxFind("users", new JsonObject());
+    }).subscribe(results -> {
+      System.out.println("Results " + results);
+    }, error -> {
+      System.out.println("Err");
+      error.printStackTrace();
+    });
+  }
+}

rx-examples/src/main/java/io/vertx/example/rxjava/eventbus/pingpong/PingPong.java

@@ -0,0 +1,36 @@
+package io.vertx.example.rxjava.eventbus.pingpong;
+
+import io.vertx.rxjava.core.AbstractVerticle;
+import io.vertx.rxjava.core.eventbus.EventBus;
+import io.vertx.example.util.Runner;
+
+public class PingPong extends AbstractVerticle {
+
+    private static final String ADDRESS = "ping-address";
+
+    // Convenience method so you can run it in your IDE
+    public static void main(String[] args) {
+        Runner.runClusteredExample(PingPong.class);
+    }
+
+    @Override
+    public void start() throws Exception {
+
+        EventBus eb = vertx.eventBus();
+
+        eb.consumer(ADDRESS)
+                .toObservable()
+                .subscribe(message -> {
+                    System.out.println("Received " + message.body());
+                    message.reply("PONG");
+                });
+
+        // Send a message every second
+        vertx.setPeriodic(1000, v -> {
+            eb.rxSend(ADDRESS, "PING")
+                    .subscribe(reply -> {
+                        System.out.println("Received reply " + reply.body());
+                    });
+        });
+    }
+}

rx-examples/src/main/java/io/vertx/example/rxjava/eventbus/pubsub/Receiver.java

@@ -0,0 +1,29 @@
+package io.vertx.example.rxjava.eventbus.pubsub;
+
+import io.vertx.example.util.Runner;
+import io.vertx.rxjava.core.AbstractVerticle;
+import io.vertx.rxjava.core.eventbus.EventBus;
+
+/*
+ * @author <a href="http://tfox.org">Tim Fox</a>
+ */
+public class Receiver extends AbstractVerticle {
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runClusteredExample(Receiver.class);
+  }
+
+
+  @Override
+  public void start() throws Exception {
+
+    EventBus eb = vertx.eventBus();
+
+    eb.consumer("news-feed").
+        toObservable().
+        subscribe(message -> System.out.println("Received news: " + message.body()));
+
+    System.out.println("Ready!");
+  }
+}

rx-examples/src/main/java/io/vertx/example/rxjava/eventbus/pubsub/Sender.java

@@ -0,0 +1,26 @@
+package io.vertx.example.rxjava.eventbus.pubsub;
+
+import io.vertx.core.AbstractVerticle;
+import io.vertx.core.eventbus.EventBus;
+import io.vertx.example.util.Runner;
+
+/*
+ * @author <a href="http://tfox.org">Tim Fox</a>
+ */
+public class Sender extends AbstractVerticle {
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runClusteredExample(Sender.class);
+  }
+
+  @Override
+  public void start() throws Exception {
+
+    EventBus eb = vertx.eventBus();
+
+    // Send a message every second
+
+    vertx.setPeriodic(1000, v -> eb.publish("news-feed", "Some news!"));
+  }
+}

rx-examples/src/main/java/io/vertx/example/reactivex/eventbus/zipreplies/Receiver.java renamed to rx-examples/src/main/java/io/vertx/example/rxjava/eventbus/zipreplies/Receiver.java

@@ -1,4 +1,4 @@
-package io.vertx.example.reactivex.scheduler.timer;
+package io.vertx.example.rxjava.scheduler.timer;
 
 import io.vertx.example.util.Runner;
 import io.vertx.rxjava.core.AbstractVerticle;