Add default FiberScheduler to rage console

lib/rage/cli.rb

@@ -3,6 +3,7 @@
 require "thor"
 require "rack"
 require "rage/version"
+require "rage/sync_fiber"
 
 module Rage
   class CLICodeGenerator < Thor

lib/rage/rspec.rb

@@ -2,6 +2,7 @@
 
 require "rack/test"
 require "json"
+require "rage/sync_fiber"
 
 # set up environment
 ENV["RAGE_ENV"] ||= "test"
@@ -14,23 +15,6 @@
 # verify the environment
 abort("The test suite is running in #{Rage.env} mode instead of 'test'!") unless Rage.env.test?
 
-# mock fiber methods as RSpec tests don't run concurrently
-class Fiber
-  def self.schedule(&block)
-    fiber = Fiber.new(blocking: true) do
-      Fiber.current.__set_id
-      Fiber.current.__set_result(block.call)
-    end
-    fiber.resume
-
-    fiber
-  end
-
-  def self.await(fibers)
-    Array(fibers).map(&:__get_result)
-  end
-end
-
 # define request helpers
 module RageRequestHelpers
   include Rack::Test::Methods

lib/rage/sync_fiber.rb

@@ -0,0 +1,16 @@
+# mock fiber methods as RSpec tests don't run concurrently
+class Fiber
+  def self.schedule(&block)
+    fiber = Fiber.new(blocking: true) do
+      Fiber.current.__set_id
+      Fiber.current.__set_result(block.call)
+    end
+    fiber.resume
+
+    fiber
+  end
+
+  def self.await(fibers)
+    Array(fibers).map(&:__get_result)
+  end
+end

spec/rage/sync_fiber_spec.rb

@@ -0,0 +1,21 @@
+require "rage/sync_fiber"
+
+RSpec.describe Fiber do
+  describe ".schedule" do
+    let(:fiber_instance) { instance_double(Fiber) }
+
+    it "runs immediately" do
+      expect(Fiber).to receive(:new).with(blocking: true).and_return(fiber_instance)
+      expect(fiber_instance).to receive(:resume).and_return(true)
+      expect(described_class.schedule { rand }).to eq(fiber_instance)
+    end
+  end
+
+  describe ".await" do
+    let(:fiber_instance) { instance_double(Fiber, __get_result: 10) }
+
+    it "immediately returns result" do
+      expect(described_class.await([fiber_instance])).to eq([10])
+    end
+  end
+end