Sha256: 8a5d401f55446eb778c3dfdffcfaafcb4f09efeb3bd6d79e4833553051d3c838
Contents?: true
Size: 1.31 KB
Versions: 32
Compression:
Stored size: 1.31 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
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)
else
# TODO: raise
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)
end
@fibers[rep]
end
end
end
Version data entries
32 entries across 32 versions & 1 rubygems