=doc,sam RecoveryCompleted handled by receiveRecover typo

akka-docs/rst/java/code/docs/persistence/PersistenceDocTest.java

@@ -143,14 +143,15 @@ public class PersistenceDocTest {
           
             @Override
             public void onReceiveRecover(Object message) {
+	      if (message instanceof RecoveryCompleted) {
+	          recoveryCompleted();
+	      }
               // ...
             }
             
             @Override
             public void onReceiveCommand(Object message) throws Exception {
-                if (message instanceof RecoveryCompleted) {
+                if (message instanceof String) {
-                    recoveryCompleted();
-                } else if (message instanceof String) {
                   // ...
                 } else {
                     unhandled(message);

akka-docs/rst/scala/code/docs/persistence/PersistenceDocSpec.scala

@@ -92,11 +92,11 @@ trait PersistenceDocSpec {
       //#recovery-completed
 
       def receiveRecover: Receive = {
+        case RecoveryCompleted => recoveryCompleted()
         case evt => //...
       }
 
       def receiveCommand: Receive = {
-        case RecoveryCompleted => recoveryCompleted()
         case msg               => //...
       }
 

akka-samples/akka-sample-persistence-java-lambda/src/main/java/doc/LambdaPersistenceDocTest.java

@@ -146,14 +146,14 @@ public class LambdaPersistenceDocTest {
 
       @Override public PartialFunction<Object, BoxedUnit> receiveRecover() {
         return ReceiveBuilder.
+          match(RecoveryCompleted.class, r -> {
+            recoveryCompleted();
+          }).
           match(String.class, this::handleEvent).build();
       }
 
       @Override public PartialFunction<Object, BoxedUnit> receiveCommand() {
         return ReceiveBuilder.
-          match(RecoveryCompleted.class, r -> {
-            recoveryCompleted();
-          }).
           match(String.class, s -> s.equals("cmd"),
             s -> persist("evt", this::handleEvent)).build();
       }