Fix javadoc

salesforce · Mar 11, 2019 · 2b57121 · 2b57121
1 parent bbccaab
commit 2b57121
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 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
@@ -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
@@ -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
@@ -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
@@ -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(