169 |
|
} |
170 |
|
|
171 |
|
/** |
172 |
< |
* A null Executor argument to SubmissionPublisher constructor throws NPE |
172 |
> |
* A null Executor argument to SubmissionPublisher constructor |
173 |
> |
* throws NullPointerException |
174 |
|
*/ |
175 |
|
public void testConstructor3() { |
176 |
|
try { |
181 |
|
|
182 |
|
/** |
183 |
|
* A negative capacity argument to SubmissionPublisher constructor |
184 |
< |
* throws IAE |
184 |
> |
* throws IllegalArgumentException |
185 |
|
*/ |
186 |
|
public void testConstructor4() { |
187 |
|
Executor e = Executors.newFixedThreadPool(1); |
193 |
|
|
194 |
|
/** |
195 |
|
* A closed publisher reports isClosed with no closedException and |
196 |
< |
* throws ISE upon attempted submission; a subsequent close or |
197 |
< |
* closeExceptionally has no additional effect. |
196 |
> |
* throws IllegalStateException upon attempted submission; a |
197 |
> |
* subsequent close or closeExceptionally has no additional |
198 |
> |
* effect. |
199 |
|
*/ |
200 |
|
public void testClose() { |
201 |
|
SubmissionPublisher<Integer> p = basicPublisher(); |
215 |
|
|
216 |
|
/** |
217 |
|
* A publisher closedExceptionally reports isClosed with the |
218 |
< |
* closedException and throws ISE upon attempted submission; a |
219 |
< |
* subsequent close or closeExceptionally has no additional |
220 |
< |
* effect. |
218 |
> |
* closedException and throws IllegalStateException upon attempted |
219 |
> |
* submission; a subsequent close or closeExceptionally has no |
220 |
> |
* additional effect. |
221 |
|
*/ |
222 |
|
public void testCloseExceptionally() { |
223 |
|
SubmissionPublisher<Integer> p = basicPublisher(); |