412 |
|
final Object x = impl.makeElement(1); |
413 |
|
final Object y = impl.makeElement(2); |
414 |
|
final ArrayList found = new ArrayList(); |
415 |
< |
Consumer<Object> spy = o -> { found.add(o); }; |
415 |
> |
Consumer<Object> spy = o -> found.add(o); |
416 |
|
c.stream().forEach(spy); |
417 |
|
assertTrue(found.isEmpty()); |
418 |
|
|
446 |
|
Runnable checkElt = () -> { |
447 |
|
threadsStarted.countDown(); |
448 |
|
while (!done.get()) |
449 |
< |
c.stream().forEach(x -> { assertSame(x, elt); }); }; |
449 |
> |
c.stream().forEach(x -> assertSame(x, elt)); }; |
450 |
|
Runnable addRemove = () -> { |
451 |
|
threadsStarted.countDown(); |
452 |
|
while (!done.get()) { |
470 |
|
final Object x = impl.makeElement(1); |
471 |
|
final Object y = impl.makeElement(2); |
472 |
|
final ArrayList found = new ArrayList(); |
473 |
< |
Consumer<Object> spy = o -> { found.add(o); }; |
473 |
> |
Consumer<Object> spy = o -> found.add(o); |
474 |
|
c.forEach(spy); |
475 |
|
assertTrue(found.isEmpty()); |
476 |
|
|
504 |
|
Runnable checkElt = () -> { |
505 |
|
threadsStarted.countDown(); |
506 |
|
while (!done.get()) |
507 |
< |
c.forEach(x -> { assertSame(x, elt); }); }; |
507 |
> |
c.forEach(x -> assertSame(x, elt)); }; |
508 |
|
Runnable addRemove = () -> { |
509 |
|
threadsStarted.countDown(); |
510 |
|
while (!done.get()) { |