class HrrRbSsh::Connection::Channel::ChannelType::Session::ProcChain

Public Class Methods

new() click to toggle source
# File lib/hrr_rb_ssh/connection/channel/channel_type/session/proc_chain.rb, line 12
def initialize
  @q = Queue.new
end

Public Instance Methods

call_next(*args) click to toggle source
# File lib/hrr_rb_ssh/connection/channel/channel_type/session/proc_chain.rb, line 18
def call_next *args
  next_proc = @q.deq
  next_proc.call ChainContext.new(self), *args
end
connect(next_proc) click to toggle source
# File lib/hrr_rb_ssh/connection/channel/channel_type/session/proc_chain.rb, line 15
def connect next_proc
  @q.enq next_proc if next_proc
end