tests/org.simantics.db.tests/src/org/simantics/db/tests/api/request/external/CachingExternalReads.java

   1 package org.simantics.db.tests.api.request.external;
   2
   3 import junit.framework.Assert;
   4
   5 import org.junit.Test;
   6 import org.simantics.Simantics;
   7 import org.simantics.db.ReadGraph;
   8 import org.simantics.db.Session;
   9 import org.simantics.db.procedure.Listener;
  10 import org.simantics.db.request.ExternalRead;
  11 import org.simantics.db.testing.cases.FreshDatabaseTest;
  12
  13 public class CachingExternalReads extends FreshDatabaseTest {
  14
  15     public static final String RESULT = "Hello World!";
  16
  17     static class MyExternalRead implements ExternalRead<String> {
  18
  19         int registerCount = 0;
  20
  21         @Override
  22         public void register(ReadGraph graph, Listener<String> procedure) {
  23             if (DEBUG)
  24                 System.out.println("register");
  25             ++registerCount;
  26             procedure.execute(RESULT);
  27         }
  28
  29         @Override
  30         public void unregistered() {
  31             if (DEBUG)
  32                 System.out.println("unregistered");
  33         }
  34
  35         public int getRegisterCount() {
  36             return registerCount;
  37         }
  38     };
  39
  40     @Test
  41     public void test() throws Exception {
  42         Session session = Simantics.getSession();
  43
  44         MyExternalRead read = new MyExternalRead();
  45
  46         for(int i=0;i<10;++i) {
  47             session.syncRequest(read, new Listener<String>() {
  48                 @Override
  49                 public void execute(String result) {
  50                     if (DEBUG)
  51                         System.out.println("=> " + result);
  52                 }
  53
  54                 @Override
  55                 public void exception(Throwable t) {
  56                     t.printStackTrace();
  57                 }
  58
  59                 @Override
  60                 public boolean isDisposed() {
  61                     return false;
  62                 }
  63
  64             });
  65         }
  66
  67         Assert.assertEquals(1, read.registerCount);
  68     }
  69 }