package org.apidesign.openfixed;

 import java.util.concurrent.CountDownLatch;

 /** Test the Calculator.createPending() behavior.

  *

  * @author Jaroslav Tulach <jtulach@netbeans.org>

  */

 public final class PostTest extends PendingTest {

     public PostTest(String testName) {

         super(testName);

     }

     @Override

     protected Calculator create() {

         return Calculator.createBatch();

     }

     public void testPostModificationEvents() throws Exception {

         // BEGIN: openfixed.usemount

         class PostListener extends BlockingListener 

         implements PostModificationListener {

             int cnt;

             @Override

             public synchronized void modification(ModificationEvent ev) {

                 // registers for callback when batch processing is over:

                 ev.postProcess(this);

                 super.modification(ev);

             }

             @Override

             public synchronized void postProcess(PostModificationEvent ev) {

                 // called when batch processing is over

                 cnt++;

             }

         // FINISH: openfixed.usemount

             public synchronized void assertPostProcess(String msg, int expected) throws InterruptedException {

                 for (int i = 0; i < 10; i++) {

                     if (cnt >= expected) {

                         break;

                     }

                     wait(1000);

                 }

                 assertEquals(msg, expected, cnt);

                 cnt = 0;

             }

         }

         PostListener bl = new PostListener();

         Calculator calc = create();

         calc.addModificationListener(bl);

         calc.add(10);

         bl.first.await();

         calc.add(1);

         calc.add(2);

         calc.add(3);

         bl.cdl.countDown();

         bl.assertPostProcess("Two postprocessings (one for 10), then for the rest", 2);

     }

 }