Sha256: ee0743262c3ff47d8d0e7b8359178c1a468a88603708686eadd8afd59f37cf3e
Contents?: true
Size: 1.4 KB
Versions: 13
Compression:
Stored size: 1.4 KB
Contents
module Libuv
class Idle < Handle
define_callback function: :on_idle
# @param thread [::Libuv::Loop] loop this idle handler will be associated
# @param callback [Proc] callback to be called when the loop is idle
def initialize(thread, callback = nil, &blk)
@loop = thread
@callback = callback || blk
idle_ptr = ::Libuv::Ext.allocate_handle_idle
error = check_result(::Libuv::Ext.idle_init(thread.handle, idle_ptr))
super(idle_ptr, error)
end
# Enables the idle handler.
def start
return if @closed
error = check_result ::Libuv::Ext.idle_start(handle, callback(:on_idle))
reject(error) if error
end
# Disables the idle handler.
def stop
return if @closed
error = check_result ::Libuv::Ext.idle_stop(handle)
reject(error) if error
end
# Used to update the callback that will be triggered on idle
#
# @param callback [Proc] the callback to be called on idle trigger
def progress(callback = nil, &blk)
@callback = callback || blk
end
private
def on_idle(handle)
begin
@callback.call
rescue Exception => e
@loop.log :error, :idle_cb, e
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems