Contents

# frozen_string_literal: true

module MTLibuv
    module Accessors
        def reactor
            thread = MTLibuv::Reactor.current
            if thread.nil?
                thread = MTLibuv::Reactor.default
                if thread.reactor_running?
                    raise 'No reactor available on this thread'
                end
            end
            thread.run { yield(thread) } if block_given?
            thread
        end

        Functions = [
            :defer, :all, :any, :finally, :update_time, :now, :lookup_error, :tcp,
            :udp, :tty, :pipe, :timer, :prepare, :check, :idle, :async, :signal,
            :work, :lookup, :fs_event, :file, :filesystem, :schedule, :next_tick,
            :stop, :reactor_thread?, :reactor_running?, :run
        ].freeze

        Functions.each do |function|
            define_method function do |*args|
                thread = MTLibuv::Reactor.current

                if thread
                    thread.send(function, *args)
                else
                    thread = MTLibuv::Reactor.default
                    if thread.reactor_running?
                        raise 'attempted MTLibuv::Reactor access on non-reactor thread'
                    else
                       thread.send(function, *args) 
                    end
                end
            end
        end
    end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
mt-libuv-4.1.04	lib/mt-libuv/mixins/accessors.rb
mt-libuv-4.1.03	lib/mt-libuv/mixins/accessors.rb
mt-libuv-4.1.02	lib/mt-libuv/mixins/accessors.rb
mt-libuv-4.1.01	lib/mt-libuv/mixins/accessors.rb
mt-libuv-4.1.0	lib/mt-libuv/mixins/accessors.rb