Class: Vertx::WorkerExecutor
- Inherits:
-
Object
- Object
- Vertx::WorkerExecutor
- Includes:
- Measured
- Defined in:
- /Users/julien/java/vertx-stack/stack-docs/target/rb/vertx/worker_executor.rb
Instance Method Summary (collapse)
- - (Object) close
- - (Object) execute_blocking(blockingCodeHandler = nil, ordered = nil)
-
- (WorkerExecutor) initialize(j_del)
constructor
A new instance of WorkerExecutor.
- - (Object) j_del
- - (Boolean) metrics_enabled?
Constructor Details
- (WorkerExecutor) initialize(j_del)
Returns a new instance of WorkerExecutor
14 15 16 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx/worker_executor.rb', line 14 def initialize(j_del) @j_del = j_del end |
Instance Method Details
- (Object) close
57 58 59 60 61 62 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx/worker_executor.rb', line 57 def close if !block_given? return @j_del.java_method(:close, []).call() end raise ArgumentError, "Invalid arguments when calling close()" end |
- (Object) execute_blocking(blockingCodeHandler = nil, ordered = nil)
47 48 49 50 51 52 53 54 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx/worker_executor.rb', line 47 def execute_blocking(blockingCodeHandler=nil,ordered=nil) if blockingCodeHandler.class == Proc && block_given? && ordered == nil return @j_del.java_method(:executeBlocking, [Java::IoVertxCore::Handler.java_class,Java::IoVertxCore::Handler.java_class]).call((Proc.new { |event| blockingCodeHandler.call(::Vertx::Util::Utils.safe_create(event,::Vertx::Future)) }),(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.from_object(ar.result) : nil) })) elsif blockingCodeHandler.class == Proc && (ordered.class == TrueClass || ordered.class == FalseClass) && block_given? return @j_del.java_method(:executeBlocking, [Java::IoVertxCore::Handler.java_class,Java::boolean.java_class,Java::IoVertxCore::Handler.java_class]).call((Proc.new { |event| blockingCodeHandler.call(::Vertx::Util::Utils.safe_create(event,::Vertx::Future)) }),ordered,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.from_object(ar.result) : nil) })) end raise ArgumentError, "Invalid arguments when calling execute_blocking(blockingCodeHandler,ordered)" end |
- (Object) j_del
19 20 21 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx/worker_executor.rb', line 19 def j_del @j_del end |
- (Boolean) metrics_enabled?
24 25 26 27 28 29 |
# File '/Users/julien/java/vertx-stack/stack-docs/target/rb/vertx/worker_executor.rb', line 24 def metrics_enabled? if !block_given? return @j_del.java_method(:isMetricsEnabled, []).call() end raise ArgumentError, "Invalid arguments when calling metrics_enabled?()" end |