Merge pull request #24 from bryanp/chg/io-close

Close the io object when the routine is finished

lib/goru/routines/io.rb

@@ -161,6 +161,13 @@ def unbridge
         @reactor.wakeup
       end
 
+      # [public]
+      #
+      def finished(...)
+        @io.close
+        super
+      end
+
       private def status_changed
         case @status
         when Routine::STATUS_FINISHED

spec/features/io/closing_spec.rb

@@ -0,0 +1,23 @@
+# frozen_string_literal: true
+
+require "goru/scheduler"
+
+RSpec.describe "closing the io object" do
+  let(:scheduler) {
+    Goru::Scheduler.new
+  }
+
+  let(:io) {
+    double(:io)
+  }
+
+  it "closes the io when the routine is finished" do
+    expect(io).to receive(:close)
+
+    scheduler.go(intent: :read, io: io) { |routine|
+      routine.finished
+    }
+
+    scheduler.wait
+  end
+end