class Orocos::Async::SubPortProxy

# File lib/orocos/async/task_context_proxy.rb, line 337
def initialize(port_proxy,subfield = Array.new)
    super(port_proxy)
    @subfield = Array(subfield).map do |field|
        if field.respond_to?(:to_i) && field.to_i.to_s == field
            field.to_i
        else
            field
        end
    end
end

# File lib/orocos/async/task_context_proxy.rb, line 374
def full_name
    super + "." + @subfield.join(".")
end

# File lib/orocos/async/task_context_proxy.rb, line 390
def last_sample
    subfield(__getobj__.last_sample,@subfield)
end

# File lib/orocos/async/task_context_proxy.rb, line 378
def name
    super + "." + @subfield.join(".")
end

# File lib/orocos/async/task_context_proxy.rb, line 386
def new_sample
    type.new
end

# File lib/orocos/async/task_context_proxy.rb, line 356
def on_data(policy = Hash.new)
    on_raw_data(policy) do |sample|
        sample = Typelib.to_ruby(sample) if sample 
        yield(sample)
    end
end

# File lib/orocos/async/task_context_proxy.rb, line 363
def on_raw_data(policy = Hash.new,&block)
    p = proc do |sample|
        block.call subfield(sample,@subfield)
    end
    super(policy,&p)
end

# File lib/orocos/async/task_context_proxy.rb, line 382
def orocos_type_name
    type.name
end

# File lib/orocos/async/task_context_proxy.rb, line 394
def raw_last_sample
    subfield(__getobj__.raw_last_sample,@subfield)
end

# File lib/orocos/async/task_context_proxy.rb, line 398
def sub_port(subfield)
    raise RuntimeError , "Port #{name} is not an output port" if !output?
    SubPortProxy.new(__getobj__,@subfield+subfield)
end

# File lib/orocos/async/task_context_proxy.rb, line 348
def to_async(options=Hash.new)
    task.to_async(options).port(port.name,:subfield => @subfield)
end

# File lib/orocos/async/task_context_proxy.rb, line 352
def to_proxy(options=Hash.new)
    self
end

# File lib/orocos/async/task_context_proxy.rb, line 403
def type
    @sub_type ||= if !@subfield.empty?
                  type ||= super
                  @subfield.each do |f|
                      type = if type.respond_to? :deference
                                 type.deference
                             else
                                 type[f]
                             end
                  end
                  type
              else
                  super
              end
end

# File lib/orocos/async/task_context_proxy.rb, line 370
def type_name
    type.name
end