Skip to content

Commit

Permalink
Fixed Javadoc issues
Browse files Browse the repository at this point in the history
  • Loading branch information
amaembo committed Nov 10, 2021
1 parent 0c2236a commit 5d06c0c
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
*
* <p>
* Example 1 (Kotlin coroutines):
* <pre>{@code
* <pre><code>
* class BlockingExampleService {
* val dispatcher: @BlockingExecutor CoroutineContext
* get() { ... }
Expand All @@ -37,26 +37,26 @@
* }
* }
*
* @Blocking fun blockingBuzz() { ... }
* &#064;Blocking fun blockingBuzz() { ... }
* }
* }</pre>
* </code></pre>
*
* <p>
* Example 2 (Java with Reactor framework):
* <pre>{@code
* <pre><code>
* class BlockingExampleService {
* private static final @BlockingExecutor Scheduler blockingScheduler =
* Schedulers.newBoundedElastic(4, 10, "executor");
*
* public Flux<String> foo(Flux<String> urls) {
* public Flux&lt;String&gt; foo(Flux&lt;String&gt; urls) {
* return urls.publishOn(blockingScheduler)
* .map(url -> blockingBuzz(url)); // no IDE warning
* .map(url -&gt; blockingBuzz(url)); // no IDE warning
* }
*
* @Blocking
* &#064;Blocking
* private String blockingBuzz(String url) { ... }
* }
* }</pre>
* </code></pre>
*
* @see Blocking
* @see NonBlocking
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
*
* <p>
* Example 1 (Kotlin coroutines):
* <pre>{@code
* <pre><code>
* class NonBlockingExampleService {
* val dispatcher: @NonBlockingExecutor CoroutineContext
* get() { ... }
Expand All @@ -38,26 +38,26 @@
* }
* }
*
* @Blocking fun blockingBuzz() { ... }
* &#064;Blocking fun blockingBuzz() { ... }
* }
* }</pre>
* </code></pre>
*
* <p>
* Example 2 (Java with Reactor framework):
* <pre>{@code
* <pre><code>
* class NonBlockingExampleService {
* private static final @NonBlockingExecutor Scheduler operationsScheduler =
* Schedulers.newParallel("parallel");
*
* public Flux<String> foo(Flux<String> urls) {
* public Flux&lt;String&gt; foo(Flux&lt;String&gt; urls) {
* return urls.publishOn(operationsScheduler)
* .filter(url -> blockingBuzz(url) != null); // IDE warning: `Possibly blocking call in non-blocking context`
* .filter(url -&gt; blockingBuzz(url) != null); // IDE warning: `Possibly blocking call in non-blocking context`
* }
*
* @Blocking
* &#064;Blocking
* private String blockingBuzz(String url) { ... }
* }
* }</pre>
* </code></pre>
* @see Blocking
* @see NonBlocking
*/
Expand Down

0 comments on commit 5d06c0c

Please sign in to comment.