From 675493ba4455ca6da98a0aee4343864300e9e645 Mon Sep 17 00:00:00 2001
From: vincentw921 <vinowang921@gmail.com>
Date: Fri, 3 Feb 2023 00:19:21 -0500
Subject: [PATCH 1/2] Fix concurrent modification exception in IStream

---
 .../stuypulse/stuylib/streams/PollingIStream.java    | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/com/stuypulse/stuylib/streams/PollingIStream.java b/src/com/stuypulse/stuylib/streams/PollingIStream.java
index 56e42512..37d02f6d 100644
--- a/src/com/stuypulse/stuylib/streams/PollingIStream.java
+++ b/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;
     }

From 07c3c496fa7ae639066740bca7bc23b48f8c1f70 Mon Sep 17 00:00:00 2001
From: vincentw921 <vinowang921@gmail.com>
Date: Fri, 3 Feb 2023 00:19:49 -0500
Subject: [PATCH 2/2] Fix concurrent modification exception in AStream,
 BStream, and VStream

---
 .../stuylib/streams/angles/PollingAStream.java       | 12 ++++++++----
 .../stuylib/streams/booleans/PollingBStream.java     | 12 ++++++++----
 .../stuylib/streams/vectors/PollingVStream.java      | 12 ++++++++----
 3 files changed, 24 insertions(+), 12 deletions(-)

diff --git a/src/com/stuypulse/stuylib/streams/angles/PollingAStream.java b/src/com/stuypulse/stuylib/streams/angles/PollingAStream.java
index feb1e258..6fa7acd6 100644
--- a/src/com/stuypulse/stuylib/streams/angles/PollingAStream.java
+++ b/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;
     }
diff --git a/src/com/stuypulse/stuylib/streams/booleans/PollingBStream.java b/src/com/stuypulse/stuylib/streams/booleans/PollingBStream.java
index 805a5c5f..419b0028 100644
--- a/src/com/stuypulse/stuylib/streams/booleans/PollingBStream.java
+++ b/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;
     }
diff --git a/src/com/stuypulse/stuylib/streams/vectors/PollingVStream.java b/src/com/stuypulse/stuylib/streams/vectors/PollingVStream.java
index b015b9f7..c7736b01 100644
--- a/src/com/stuypulse/stuylib/streams/vectors/PollingVStream.java
+++ b/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;
     }