Testing incremental dependency tracking.

Version 0.3.0

ragconnect.tests/src/test/java/org/jastadd/ragconnect/tests/DefaultOnlyReadTest.java

@@ -43,13 +43,16 @@ public class DefaultOnlyReadTest extends AbstractMqttTest {
   private MqttHandler sender;
 
   @Override
-  public void closeConnections() {
-    if (sender != null) {
-      sender.close();
-    }
-    if (model != null) {
-      model.ragconnectCloseConnections();
-    }
+  protected void createModel() {
+    model = new A();
+    integers = new NativeTypes();
+    model.addNativeTypes(integers);
+    floats = new NativeTypes();
+    model.addNativeTypes(floats);
+    chars = new NativeTypes();
+    model.addNativeTypes(chars);
+    allBoxed = new BoxedTypes();
+    model.addBoxedTypes(allBoxed);
   }
 
   @Override
@@ -74,6 +77,11 @@ public class DefaultOnlyReadTest extends AbstractMqttTest {
     assertTrue(sender.waitUntilReady(2, TimeUnit.SECONDS));
   }
 
+  @Override
+  protected void communicateSendInitialValue() {
+    // empty
+  }
+
   @Override
   protected void communicateOnlyUpdatedValue() throws InterruptedException {
     final int expectedIntValue = 1;
@@ -118,21 +126,13 @@ public class DefaultOnlyReadTest extends AbstractMqttTest {
   }
 
   @Override
-  protected void communicateSendInitialValue() {
-    // empty
-  }
-
-  @Override
-  protected void createModel() {
-    model = new A();
-    integers = new NativeTypes();
-    model.addNativeTypes(integers);
-    floats = new NativeTypes();
-    model.addNativeTypes(floats);
-    chars = new NativeTypes();
-    model.addNativeTypes(chars);
-    allBoxed = new BoxedTypes();
-    model.addBoxedTypes(allBoxed);
+  public void closeConnections() {
+    if (sender != null) {
+      sender.close();
+    }
+    if (model != null) {
+      model.ragconnectCloseConnections();
+    }
   }
 
 }