Skip to content

Commit 175f7de

Browse files
authored
2.x: Fix MulticastProcessor JavaDoc warnings (#6030)
1 parent 6fefdc6 commit 175f7de

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/io/reactivex/processors/MulticastProcessor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,14 +102,14 @@
102102
* <p>
103103
* Example:
104104
* <pre><code>
105-
MulticastProcessor&lt;Integer> mp = Flowable.range(1, 10)
105+
MulticastProcessor&lt;Integer&gt; mp = Flowable.range(1, 10)
106106
.subscribeWith(MulticastProcessor.create());
107107
108108
mp.test().assertResult(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
109109
110110
// --------------------
111111
112-
MulticastProcessor&lt;Integer> mp2 = MulticastProcessor.create(4);
112+
MulticastProcessor&lt;Integer&gt; mp2 = MulticastProcessor.create(4);
113113
mp2.start();
114114
115115
assertTrue(mp2.offer(1));

0 commit comments

Comments
 (0)