Missing Multipeer snippet for Java / Kotlin (#1008)

Author: borrrden

modules/android/examples/kotlin_snippets/app/src/main/kotlin/com/couchbase/codesnippets/MultipeerExamples.kt

@@ -257,6 +257,22 @@ class MultipeerExamples {
         // end::multipeer-peer-discovery-listener[]
     }
 
+    fun peerReplicatorStatus()  {
+        val replicator = createMultipeerReplicator()
+        // tag::multipeer-replicator-status-listener[]
+        //val activities = ["stopped", "offline", "connecting", "idle", "busy"]
+        val token = replicator.addPeerReplicatorStatusListener { status ->
+            val direction = if(status.isOutgoing) "outgoing" else "incoming"
+            val activity = status.status.activityLevel.name.lowercase()
+            val error = status.status.error?.message ?: "none"
+            Log.i(TAG, "Peer Replicator Status - Peer ID: $status, " +
+                    "Direction: $direction, " +
+                    "Activity: $activity" +
+                    "Error: $error")
+        }
+        // end::multipeer-replicator-status-listener[]
+    }
+
     fun peerDocumentReplication() {
         val replicator = createMultipeerReplicator()
 

modules/java/examples/snippets/common/main/java/com/couchbase/codesnippets/MultipeerExamples.java

@@ -267,6 +267,20 @@ public void peerDiscoveryListener() throws CouchbaseLiteException, CertificateEx
         // end::multipeer-peer-discovery-listener[]
     }
 
+    public void peerReplicatorStatus() throws CouchbaseLiteException, CertificateException {
+        final MultipeerReplicator replicator = createMultipeerReplicator();
+
+        // tag::multipeer-peer-discovery-listener[]
+        final ListenerToken token = replicator.addPeerReplicatorStatusListener(status -> {
+            final String direction = status.isOutgoing() ? "outgoing" : "incoming";
+            final String activity = status.getStatus().getActivityLevel().name().toLowerCase();
+            final String error = status.getStatus().getError() != null ? status.getStatus().getError().getMessage() : "none";
+            Log.i(TAG, String.format("Peer Replicator Status - Peer ID: %s, Direction: %s, Activity: %s, Error: %s",
+                    status, direction, activity, error));
+        });
+        // end::multipeer-peer-discovery-listener[]
+    }
+
     public void peerDocumentReplication() throws CouchbaseLiteException, CertificateException {
         final MultipeerReplicator replicator = createMultipeerReplicator();