Making createAsker private, adding docs for 'to', changing Java API to be symmetric to Java

akka-actor/src/main/scala/akka/pattern/AskSupport.scala

@@ -183,7 +183,10 @@ trait AskSupport {
     }
   }
 
-  def createAsker(provider: ActorRefProvider, timeout: Timeout): PromiseActorRef = {
+  /**
+   * INTERNAL AKKA USE ONLY
+   */
+  private[akka] def createAsker(provider: ActorRefProvider, timeout: Timeout): PromiseActorRef = {
     val path = provider.tempPath()
     val result = Promise[Any]()(provider.dispatcher)
     val a = new PromiseActorRef(provider, path, provider.tempContainer, result, provider.deathWatch)

akka-actor/src/main/scala/akka/pattern/Patterns.scala

@@ -83,10 +83,10 @@ object Patterns {
    *   // apply some transformation (i.e. enrich with request info)
    *   final Future<Object> transformed = f.map(new akka.japi.Function<Object, Object>() { ... });
    *   // send it on to the next stage
-   *   Patterns.pipe(transformed, nextActor);
+   *   Patterns.pipe(transformed).to(nextActor);
    * }}}
    */
-  def pipe[T](future: Future[T], recipient: ActorRef): Future[T] = scalaPipe(future) pipeTo recipient
+  def pipe[T](future: Future[T]): PipeableFuture[T] = scalaPipe(future)
 
   /**
    * Returns a [[akka.dispatch.Future]] that will be completed with success (value `true`) when

akka-actor/src/main/scala/akka/pattern/PipeToSupport.scala

@@ -25,9 +25,14 @@ trait PipeToSupport {
    * Import this implicit conversion to gain the `pipeTo` method on [[akka.dispatch.Future]]:
    *
    * {{{
-   * import akka.pattern.pipeTo
+   * import akka.pattern.pipe
    *
    * Future { doExpensiveCalc() } pipeTo nextActor
+   *
+   * or
+   *
+   * pipe(someFuture) to nextActor
+   *
    * }}}
    */
   implicit def pipe[T](future: Future[T]): PipeableFuture[T] = new PipeableFuture(future)

akka-docs/java/code/akka/docs/actor/UntypedActorDocTestBase.java

@@ -247,7 +247,7 @@ public class UntypedActorDocTestBase {
       }
     });
 
-    pipe(transformed, actorC);
+    pipe(transformed).to(actorC);
     //#ask-pipe
     system.shutdown();
   }

akka-docs/java/code/akka/docs/actor/japi/FaultHandlingDocSample.java

@@ -151,7 +151,8 @@ public class FaultHandlingDocSample {
             public Progress apply(CurrentCount c) {
                 return new Progress(100.0 * c.count / totalCount);
             }
-        }), progressListener);
+        }))
+        .to(progressListener);
       } else {
         unhandled(msg);
       }