From 2b571218655674450ddd0b45af38b5bb0afd0915 Mon Sep 17 00:00:00 2001
From: Ryan Michela <rmichela@salesforce.com>
Date: Mon, 11 Mar 2019 11:49:45 -0700
Subject: [PATCH] Fix javadoc

---
 .../java/com/salesforce/reactorgrpc/stub/ClientCalls.java | 8 ++++----
 .../java/com/salesforce/reactorgrpc/stub/ServerCalls.java | 8 ++++----
 .../main/java/com/salesforce/rxgrpc/stub/ClientCalls.java | 8 ++++----
 .../main/java/com/salesforce/rxgrpc/stub/ServerCalls.java | 8 ++++----
 4 files changed, 16 insertions(+), 16 deletions(-)

diff --git a/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ClientCalls.java b/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ClientCalls.java
index cf8a3cbf..478bf096 100644
--- a/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ClientCalls.java
+++ b/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ClientCalls.java
@@ -27,7 +27,7 @@ private ClientCalls() {
     }
 
     /**
-     * Implements a unary → unary call using {@link Mono} -> {@link Mono}.
+     * Implements a unary → unary call using {@link Mono} → {@link Mono}.
      */
     public static <TRequest, TResponse> Mono<TResponse> oneToOne(
             Mono<TRequest> monoSource,
@@ -60,7 +60,7 @@ public void onCompleted() {
     }
 
     /**
-     * Implements a unary → stream call as {@link Mono} -> {@link Flux}, where the server responds with a
+     * Implements a unary → stream call as {@link Mono} → {@link Flux}, where the server responds with a
      * stream of messages.
      */
     public static <TRequest, TResponse> Flux<TResponse> oneToMany(
@@ -82,7 +82,7 @@ public static <TRequest, TResponse> Flux<TResponse> oneToMany(
     }
 
     /**
-     * Implements a stream → unary call as {@link Flux} -> {@link Mono}, where the client transits a stream of
+     * Implements a stream → unary call as {@link Flux} → {@link Mono}, where the client transits a stream of
      * messages.
      */
     @SuppressWarnings("unchecked")
@@ -107,7 +107,7 @@ public static <TRequest, TResponse> Mono<TResponse> manyToOne(
     }
 
     /**
-     * Implements a bidirectional stream → stream call as {@link Flux} -> {@link Flux}, where both the client
+     * Implements a bidirectional stream → stream call as {@link Flux} → {@link Flux}, where both the client
      * and the server independently stream to each other.
      */
     @SuppressWarnings("unchecked")
diff --git a/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ServerCalls.java b/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ServerCalls.java
index 881b2b5e..3f19dc85 100644
--- a/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ServerCalls.java
+++ b/reactor/reactor-grpc-stub/src/main/java/com/salesforce/reactorgrpc/stub/ServerCalls.java
@@ -29,7 +29,7 @@ private ServerCalls() {
     }
 
     /**
-     * Implements a unary → unary call using {@link Mono} -> {@link Mono}.
+     * Implements a unary → unary call using {@link Mono} → {@link Mono}.
      */
     public static <TRequest, TResponse> void oneToOne(
             TRequest request, StreamObserver<TResponse> responseObserver,
@@ -54,7 +54,7 @@ public static <TRequest, TResponse> void oneToOne(
     }
 
     /**
-     * Implements a unary → stream call as {@link Mono} -> {@link Flux}, where the server responds with a
+     * Implements a unary → stream call as {@link Mono} → {@link Flux}, where the server responds with a
      * stream of messages.
      */
     public static <TRequest, TResponse> void oneToMany(
@@ -72,7 +72,7 @@ public static <TRequest, TResponse> void oneToMany(
     }
 
     /**
-     * Implements a stream → unary call as {@link Flux} -> {@link Mono}, where the client transits a stream of
+     * Implements a stream → unary call as {@link Flux} → {@link Mono}, where the client transits a stream of
      * messages.
      */
     public static <TRequest, TResponse> StreamObserver<TRequest> manyToOne(
@@ -107,7 +107,7 @@ public static <TRequest, TResponse> StreamObserver<TRequest> manyToOne(
     }
 
     /**
-     * Implements a bidirectional stream → stream call as {@link Flux} -> {@link Flux}, where both the client
+     * Implements a bidirectional stream → stream call as {@link Flux} → {@link Flux}, where both the client
      * and the server independently stream to each other.
      */
     public static <TRequest, TResponse> StreamObserver<TRequest> manyToMany(
diff --git a/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ClientCalls.java b/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ClientCalls.java
index 9764e2d9..fd80dc3b 100644
--- a/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ClientCalls.java
+++ b/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ClientCalls.java
@@ -29,7 +29,7 @@ private ClientCalls() {
     }
 
     /**
-     * Implements a unary → unary call using {@link Single} -> {@link Single}.
+     * Implements a unary → unary call using {@link Single} → {@link Single}.
      */
     public static <TRequest, TResponse> Single<TResponse> oneToOne(
             final Single<TRequest> rxRequest,
@@ -77,7 +77,7 @@ public void accept(Throwable t) {
     }
 
     /**
-     * Implements a unary → stream call as {@link Single} -> {@link Flowable}, where the server responds with a
+     * Implements a unary → stream call as {@link Single} → {@link Flowable}, where the server responds with a
      * stream of messages.
      */
     public static <TRequest, TResponse> Flowable<TResponse> oneToMany(
@@ -102,7 +102,7 @@ public Publisher<? extends TResponse> apply(TRequest request) {
     }
 
     /**
-     * Implements a stream → unary call as {@link Flowable} -> {@link Single}, where the client transits a stream of
+     * Implements a stream → unary call as {@link Flowable} → {@link Single}, where the client transits a stream of
      * messages.
      */
     @SuppressWarnings("unchecked")
@@ -137,7 +137,7 @@ public void run() {
     }
 
     /**
-     * Implements a bidirectional stream → stream call as {@link Flowable} -> {@link Flowable}, where both the client
+     * Implements a bidirectional stream → stream call as {@link Flowable} → {@link Flowable}, where both the client
      * and the server independently stream to each other.
      */
     @SuppressWarnings("unchecked")
diff --git a/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java b/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java
index c12eec27..2cdffd2f 100644
--- a/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java
+++ b/rx-java/rxgrpc-stub/src/main/java/com/salesforce/rxgrpc/stub/ServerCalls.java
@@ -29,7 +29,7 @@ private ServerCalls() {
     }
 
     /**
-     * Implements a unary → unary call using {@link Single} -> {@link Single}.
+     * Implements a unary → unary call using {@link Single} → {@link Single}.
      */
     public static <TRequest, TResponse> void oneToOne(
             final TRequest request,
@@ -63,7 +63,7 @@ public void accept(Throwable throwable) {
     }
 
     /**
-     * Implements a unary → stream call as {@link Single} -> {@link Flowable}, where the server responds with a
+     * Implements a unary → stream call as {@link Single} → {@link Flowable}, where the server responds with a
      * stream of messages.
      */
     public static <TRequest, TResponse> void oneToMany(
@@ -83,7 +83,7 @@ public static <TRequest, TResponse> void oneToMany(
     }
 
     /**
-     * Implements a stream → unary call as {@link Flowable} -> {@link Single}, where the client transits a stream of
+     * Implements a stream → unary call as {@link Flowable} → {@link Single}, where the client transits a stream of
      * messages.
      */
     public static <TRequest, TResponse> StreamObserver<TRequest> manyToOne(
@@ -124,7 +124,7 @@ public void accept(Throwable throwable) {
     }
 
     /**
-     * Implements a bidirectional stream → stream call as {@link Flowable} -> {@link Flowable}, where both the client
+     * Implements a bidirectional stream → stream call as {@link Flowable} → {@link Flowable}, where both the client
      * and the server independently stream to each other.
      */
     public static <TRequest, TResponse> StreamObserver<TRequest> manyToMany(