Fix Concurrent Modification Patch [AStream, BStream, IStream, VStream]

src/com/stuypulse/stuylib/streams/PollingIStream.java

@@ -29,19 +29,23 @@ public PollingIStream(IStream stream, double dt) {
         }
 
         mResult = 0.0;
-        mPoller = new Notifier(() -> mResult = stream.get());
+        mPoller = new Notifier(() -> this.set(stream.get()));
         mPoller.startPeriodic(dt);
     }
 
-    public double get() {
+    private final synchronized void set(double result) {
+        mResult = result;
+    }
+
+    public final synchronized double get() {
         return mResult;
     }
 
-    protected void finalize() {
+    protected synchronized void finalize() {
         close();
     }
 
-    public void close() {
+    public synchronized void close() {
         mPoller.close();
         mResult = 0.0;
     }

src/com/stuypulse/stuylib/streams/angles/PollingAStream.java

@@ -31,19 +31,23 @@ public PollingAStream(AStream stream, double dt) {
         }
 
         mResult = Angle.kNull;
-        mPoller = new Notifier(() -> mResult = stream.get());
+        mPoller = new Notifier(() -> this.set(stream.get()));
         mPoller.startPeriodic(dt);
     }
 
-    public Angle get() {
+    private final synchronized void set(Angle result) {
+        mResult = result;
+    }
+
+    public final synchronized Angle get() {
         return mResult;
     }
 
-    protected void finalize() {
+    protected synchronized void finalize() {
         close();
     }
 
-    public void close() {
+    public synchronized void close() {
         mPoller.close();
         mResult = Angle.kNull;
     }

src/com/stuypulse/stuylib/streams/booleans/PollingBStream.java

@@ -31,19 +31,23 @@ public PollingBStream(BStream stream, double dt) {
         }
 
         mResult = false;
-        mPoller = new Notifier(() -> mResult = stream.get());
+        mPoller = new Notifier(() -> this.set(stream.get()));
         mPoller.startPeriodic(dt);
     }
 
-    public boolean get() {
+    private final synchronized void set(boolean result) {
+        mResult = result;
+    }
+
+    public final synchronized boolean get() {
         return mResult;
     }
 
-    protected void finalize() {
+    protected synchronized void finalize() {
         close();
     }
 
-    public void close() {
+    public synchronized void close() {
         mPoller.close();
         mResult = false;
     }

src/com/stuypulse/stuylib/streams/vectors/PollingVStream.java

@@ -31,19 +31,23 @@ public PollingVStream(VStream stream, double dt) {
         }
 
         mResult = Vector2D.kOrigin;
-        mPoller = new Notifier(() -> mResult = stream.get());
+        mPoller = new Notifier(() -> this.set(stream.get()));
         mPoller.startPeriodic(dt);
     }
 
-    public Vector2D get() {
+    private final synchronized void set(Vector2D result) {
+        mResult = result;
+    }
+
+    public final synchronized Vector2D get() {
         return mResult;
     }
 
-    protected void finalize() {
+    protected synchronized void finalize() {
         close();
     }
 
-    public void close() {
+    public synchronized void close() {
         mPoller.close();
         mResult = Vector2D.kOrigin;
     }