File tree Expand file tree Collapse file tree 2 files changed +16
-16
lines changed
java8/src/main/java/org/jetbrains/annotations Expand file tree Collapse file tree 2 files changed +16
-16
lines changed Original file line number Diff line number Diff line change 2626 *
2727 * <p>
2828 * Example 1 (Kotlin coroutines):
29- * <pre>{@ code
29+ * <pre>< code>
3030 * class BlockingExampleService {
3131 * val dispatcher: @BlockingExecutor CoroutineContext
3232 * get() { ... }
3737 * }
3838 * }
3939 *
40- * @ Blocking fun blockingBuzz() { ... }
40+ * @ Blocking fun blockingBuzz() { ... }
4141 * }
42- * } </pre>
42+ * </code> </pre>
4343 *
4444 * <p>
4545 * Example 2 (Java with Reactor framework):
46- * <pre>{@ code
46+ * <pre>< code>
4747 * class BlockingExampleService {
4848 * private static final @BlockingExecutor Scheduler blockingScheduler =
4949 * Schedulers.newBoundedElastic(4, 10, "executor");
5050 *
51- * public Flux< String> foo(Flux< String> urls) {
51+ * public Flux< String> foo(Flux< String> urls) {
5252 * return urls.publishOn(blockingScheduler)
53- * .map(url -> blockingBuzz(url)); // no IDE warning
53+ * .map(url -> blockingBuzz(url)); // no IDE warning
5454 * }
5555 *
56- * @ Blocking
56+ * @ Blocking
5757 * private String blockingBuzz(String url) { ... }
5858 * }
59- * } </pre>
59+ * </code> </pre>
6060 *
6161 * @see Blocking
6262 * @see NonBlocking
Original file line number Diff line number Diff line change 2727 *
2828 * <p>
2929 * Example 1 (Kotlin coroutines):
30- * <pre>{@ code
30+ * <pre>< code>
3131 * class NonBlockingExampleService {
3232 * val dispatcher: @NonBlockingExecutor CoroutineContext
3333 * get() { ... }
3838 * }
3939 * }
4040 *
41- * @ Blocking fun blockingBuzz() { ... }
41+ * @ Blocking fun blockingBuzz() { ... }
4242 * }
43- * } </pre>
43+ * </code> </pre>
4444 *
4545 * <p>
4646 * Example 2 (Java with Reactor framework):
47- * <pre>{@ code
47+ * <pre>< code>
4848 * class NonBlockingExampleService {
4949 * private static final @NonBlockingExecutor Scheduler operationsScheduler =
5050 * Schedulers.newParallel("parallel");
5151 *
52- * public Flux< String> foo(Flux< String> urls) {
52+ * public Flux< String> foo(Flux< String> urls) {
5353 * return urls.publishOn(operationsScheduler)
54- * .filter(url -> blockingBuzz(url) != null); // IDE warning: `Possibly blocking call in non-blocking context`
54+ * .filter(url -> blockingBuzz(url) != null); // IDE warning: `Possibly blocking call in non-blocking context`
5555 * }
5656 *
57- * @ Blocking
57+ * @ Blocking
5858 * private String blockingBuzz(String url) { ... }
5959 * }
60- * } </pre>
60+ * </code> </pre>
6161 * @see Blocking
6262 * @see NonBlocking
6363 */
You can’t perform that action at this time.
0 commit comments