Class: Quark::Quark::Callback

Inherits:
Object
  • Object
show all
Extended by:
DatawireQuarkCore::Static
Defined in:
lib/quark.rb

Constant Summary

Constants included from DatawireQuarkCore::Static

DatawireQuarkCore::Static::Unassigned

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from DatawireQuarkCore::Static

_lazy_statics, static, unlazy_statics

Constructor Details

#initialize(callable, next_) ⇒ Callback

Returns a new instance of Callback.



2751
2752
2753
2754
2755
2756
2757
2758
 
# File 'lib/quark.rb', line 2751

def initialize(callable, next_)
    
    super()
    (self)._callable = callable
    (self)._next = next_

    nil
end

Instance Attribute Details

#_callable ⇒ Object

Returns the value of attribute _callable.



2744
2745
2746
 
# File 'lib/quark.rb', line 2744

def _callable
  @_callable
end

#_next ⇒ Object

Returns the value of attribute _next.



2744
2745
2746
 
# File 'lib/quark.rb', line 2744

def _next
  @_next
end

Instance Method Details

#__init_fields__ ⇒ Object 



2809
2810
2811
2812
2813
2814
2815
2816
 
# File 'lib/quark.rb', line 2809

def __init_fields__()
    
    super
    self._callable = nil
    self._next = nil

    nil
end

#_getClass ⇒ Object 



2771
2772
2773
2774
2775
2776
 
# File 'lib/quark.rb', line 2771

def _getClass()
    
    return "quark._Callback"

    nil
end

#_getField(name) ⇒ Object 



2778
2779
2780
2781
2782
2783
2784
2785
2786
2787
2788
2789
2790
2791
2792
 
# File 'lib/quark.rb', line 2778

def _getField(name)
    
    if ((name) == ("_context"))
        return (self)._context
    end
    if ((name) == ("_callable"))
        return (self)._callable
    end
    if ((name) == ("_next"))
        return (self)._next
    end
    return nil

    nil
end

#_setField(name, value) ⇒ Object 



2794
2795
2796
2797
2798
2799
2800
2801
2802
2803
2804
2805
2806
2807
 
# File 'lib/quark.rb', line 2794

def _setField(name, value)
    
    if ((name) == ("_context"))
        (self)._context = ::DatawireQuarkCore.cast(value) { ::Quark.quark.concurrent.Context }
    end
    if ((name) == ("_callable"))
        (self)._callable = ::DatawireQuarkCore.cast(value) { ::Quark.quark.UnaryCallable }
    end
    if ((name) == ("_next"))
        (self)._next = ::DatawireQuarkCore.cast(value) { ::Quark.quark.Promise }
    end

    nil
end

#call(result) ⇒ Object 



2763
2764
2765
2766
2767
2768
2769
 
# File 'lib/quark.rb', line 2763

def call(result)
    
    event = ::Quark.quark._CallbackEvent.new((self)._callable, (self)._next, result, self)
    (self.getContext()).collector.put(event)

    nil
end