class NestedScheduler::Results::ResultCollector(T)

Overview

Returns an array of the specified type, in unspecified order. Will cancel the pool on any errors and then it will re-raise the error when the pool is done.

Defined in:

nested_scheduler/results/result_collector.cr

Constructors

Instance Method Summary

Instance methods inherited from class NestedScheduler::Result

init(&block : -> _) : -> init, register_error(pool, fiber, error) register_error, reraise_on_error(&) reraise_on_error, result result

Constructor methods inherited from class NestedScheduler::Result

new new

Constructor Detail

def self.new #

[View source]

Instance Method Detail

def error : Exception | Nil #

[View source]
def error=(error : Exception | Nil) #

[View source]
def init(&block : -> _) : -> #

[View source]
def name : String | Nil #

[View source]
def name=(name : String | Nil) #

[View source]
def register_error(pool, fiber, error) #

TODO Figure out how to handle cancellation of pool/fiber?


[View source]
def result : Array(T) #

[View source]