Minor fixes

softwaremill · Jan 5, 2024 · 48ba680 · 48ba680
1 parent e5527c2
commit 48ba680
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/core/src/main/java/com/softwaremill/jox/Channel.java b/core/src/main/java/com/softwaremill/jox/Channel.java
@@ -121,7 +121,6 @@ public Channel() {
 
     /**
      * Creates a buffered channel (when capacity is positive), or a rendezvous channel if the capacity is 0.
-     * Capacity cannot be negative.
      */
     public Channel(int capacity) {
         if (capacity < UNLIMITED_CAPACITY) {

diff --git a/core/src/main/java/com/softwaremill/jox/Segment.java b/core/src/main/java/com/softwaremill/jox/Segment.java
@@ -41,11 +41,11 @@ private enum State {
     private final AtomicInteger pointers_notProcessedAndInterrupted;
     private final boolean isRendezvousOrUnlimited;
 
-    Segment(long id, Segment prev, int pointers, boolean isRendezvous) {
+    Segment(long id, Segment prev, int pointers, boolean isRendezvousOrUnlimited) {
         this.id = id;
         this.prev = new AtomicReference<>(prev);
         this.pointers_notProcessedAndInterrupted = new AtomicInteger(SEGMENT_SIZE + (pointers << POINTERS_SHIFT));
-        this.isRendezvousOrUnlimited = isRendezvous;
+        this.isRendezvousOrUnlimited = isRendezvousOrUnlimited;
     }
 
     long getId() {