fix(pipeline): close in finalize

spider-gazelle · Jul 3, 2023 · d893af6 · d893af6
1 parent 11a91b4
commit d893af6
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/shard.yml b/shard.yml
@@ -1,5 +1,5 @@
 name: tasker
-version: 2.1.2
+version: 2.1.3
 crystal: ">= 0.36.1"
 
 dependencies:

diff --git a/src/tasker/pipeline.cr b/src/tasker/pipeline.cr
@@ -77,7 +77,7 @@ class Tasker
 
     # :nodoc:
     def finalize
-      stop
+      close
     end
 
     # shutdown processing
@@ -96,8 +96,8 @@ class Tasker
         begin
           @idle = true
           input = @in.receive
-          t1 = Time.monotonic
           @idle = false
+          t1 = Time.monotonic
           output = @work.call input
           t2 = Time.monotonic
           @time = t2 - t1