update comment

cloudamqp · Dec 2, 2024 · 922968c · 922968c
1 parent 34a971c
commit 922968c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lavinmq/config.cr b/src/lavinmq/config.cr
@@ -60,8 +60,8 @@ module LavinMQ
     property consumer_timeout : UInt64? = nil
     property consumer_timeout_loop_interval = 60 # seconds
     property default_consumer_prefetch = UInt16::MAX
-    property yield_each_received_bytes = 131_072    # after how many received bytes the read_loop fiber yields
-    property yield_each_delivered_bytes = 1_048_576 # after how many delivered bytes the deliver_loop fiber yields
+    property yield_each_received_bytes = 131_072 # number of bytes received from a publisher before yielding to other fibers
+    property yield_each_delivered_bytes = 1_048_576 # number of bytes sent to a consumer before yielding to other fibers
     @@instance : Config = self.new
 
     def self.instance : LavinMQ::Config