Address further technical feedback

Author: mcmorisi

source/includes/usage-examples/index-code-examples.java

@@ -34,24 +34,24 @@ public static void main(String[] args) {
             MongoCollection<Document> collection = database.getCollection("movies");
 
             // start-single-field
-            Publisher<String> result = collection.createIndex(Indexes.ascending("<field name>"));
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.ascending("<field name>"));
+            Mono.from(publisher).block();
             // end-single-field
 
             // start-compound
-            Publisher<String> result = collection.createIndex(Indexes.ascending("<field name 1>", "<field name 2>"));
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.ascending("<field name 1>", "<field name 2>"));
+            Mono.from(publisher).block();
             // end-compound
 
             // start-multikey
-            Publisher<String> result = collection.createIndex(Indexes.ascending("<array field name>"));
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.ascending("<array field name>"));
+            Mono.from(publisher).block();
             // end-multikey
 
             // start-search-create
             Document index = new Document("mappings", new Document("dynamic", true));
-            Publisher<String> result = collection.createSearchIndex("<index name>", index);
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createSearchIndex("<index name>", index);
+            Mono.from(publisher).block();
             // end-search-create
 
             // start-search-list
@@ -64,34 +64,34 @@ public static void main(String[] args) {
 
             // start-search-update
             Document newIndex = new Document("mappings", new Document("dynamic", true));
-            Publisher<Void> result = collection.updateSearchIndex("<index name>", newIndex);
-            Mono.from(result).block();
+            Publisher<Void> publisher = collection.updateSearchIndex("<index name>", newIndex);
+            Mono.from(publisher).block();
             // end-search-update
 
             // start-search-delete
-            Publisher<Void> result = collection.dropIndex("<index name>");
-            Mono.from(result).block();
+            Publisher<Void> publisher = collection.dropIndex("<index name>");
+            Mono.from(publisher).block();
             // end-search-delete
 
             // start-text
-            Publisher<String> result = collection.createIndex(Indexes.text("<field name>"));
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.text("<field name>"));
+            Mono.from(publisher).block();
             // end-text
 
             // start-geo
-            Publisher<String> result = collection.createIndex(Indexes.geo2dsphere("<GeoJSON object field>"));
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.geo2dsphere("<GeoJSON object field>"));
+            Mono.from(publisher).block();
             // end-geo
 
             // start-unique
             IndexOptions indexOptions = new IndexOptions().unique(true);
-            Publisher<String> result = collection.createIndex(Indexes.ascending("<field name>"), indexOptions);
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.ascending("<field name>"), indexOptions);
+            Mono.from(publisher).block();
             // end-unique
 
             // start-wildcard
-            Publisher<String> result = collection.createIndex(Indexes.ascending("$**"));
-            Mono.from(result).block();
+            Publisher<String> publisher = collection.createIndex(Indexes.ascending("$**"));
+            Mono.from(publisher).block();
             // end-wildcard
 
             // start-clustered
@@ -109,8 +109,8 @@ public static void main(String[] args) {
             // end-clustered
 
             // start-remove
-            Publisher<Void> result = collection.dropIndex("<index name>");
-            Mono.from(result).block();
+            Publisher<Void> publisher = collection.dropIndex("<index name>");
+            Mono.from(publisher).block();
             // end-remove
         }
     }

source/indexes.txt

@@ -35,6 +35,32 @@ To use an example from this page, copy the code example into the
 Be sure to replace all placeholders in the code examples, such as ``<connection string URI>``, with
 the relevant values for your MongoDB deployment.
 
+Project Reactor Implementation
+~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+This guide uses the {+pr+} library to consume ``Publisher`` instances returned
+by the {+driver-short+} methods. To learn more about the {+pr+} library
+and how to use it, see `Getting Started <https://projectreactor.io/docs/core/release/reference/#getting-started>`__
+in the Reactor documentation.
+
+There are also other ways to consume ``Publisher`` instances. You can use one of many alternative libraries such as
+`RxJava <https://github.com/ReactiveX/RxJava>`__ or call ``Publisher.subscribe()`` directly and pass your own
+implementation of a ``Subscriber``.
+
+This guide uses the ``Mono.block()`` method from Reactor to subscribe to a ``Publisher`` and block the current
+thread until the ``Publisher`` reaches its terminal state. To learn more about the Reactive Streams initiative, see `Reactive Streams <https://www.reactive-streams.org/>`__.
+
+.. important:: Publishers Returned are Cold
+
+   All ``Publisher`` instances returned by the {+driver-short+} methods are cold,
+   which means that the corresponding operation does not happen unless you
+   subscribe to the returned ``Publisher``. We recommend only subscribing to 
+   the returned ``Publisher`` once, because subscribing more than once can lead
+   to errors. 
+
+Sample Application
+~~~~~~~~~~~~~~~~~~
+
 .. _java-rs-index-sample:
 
 .. include:: /includes/usage-examples/sample-index-app-intro.rst