Sha256: 14aae749c52128acbe3e2ce187cb37df62af7a0a9c261921e42dd2a89d7a9e41
Contents?: true
Size: 1.53 KB
Versions: 9
Compression:
Stored size: 1.53 KB
Contents
# frozen_string_literal: true
module Nanoc::Int::Compiler::Phases
# Provides functionality for suspending and resuming item rep compilation (using fibers).
class Resume < Abstract
include Nanoc::Int::ContractsSupport
DONE = Object.new
def initialize(wrapped:)
super(wrapped: wrapped)
end
contract Nanoc::Int::ItemRep, C::KeywordArgs[is_outdated: C::Bool], C::Func[C::None => C::Any] => C::Any
def run(rep, is_outdated:)
fiber = fiber_for(rep, is_outdated: is_outdated) { yield }
while fiber.alive?
Nanoc::Int::NotificationCenter.post(:compilation_started, rep)
res = fiber.resume
case res
when Nanoc::Int::Errors::UnmetDependency
Nanoc::Int::NotificationCenter.post(:compilation_suspended, rep, res)
raise(res)
when Proc
fiber.resume(res.call)
when DONE # rubocop:disable Lint/EmptyWhen
# ignore
else
raise Nanoc::Int::Errors::InternalInconsistency.new(
"Fiber yielded object of unexpected type #{res.class}",
)
end
end
Nanoc::Int::NotificationCenter.post(:compilation_ended, rep)
end
private
contract Nanoc::Int::ItemRep, C::KeywordArgs[is_outdated: C::Bool], C::Func[C::None => C::Any] => Fiber
def fiber_for(rep, is_outdated:) # rubocop:disable Lint/UnusedMethodArgument
@fibers ||= {}
@fibers[rep] ||=
Fiber.new do
yield
@fibers.delete(rep)
DONE
end
@fibers[rep]
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems