in lib/aws/kclrb/kcl_process.rb [26:35]
def initialize(processor, input = $stdin, output = $stdout, error = $stderr)
if processor.version == 1
@processor = Aws::KCLrb::V2::V2ToV1Adapter.new(processor)
else
@processor = processor
end
@io_proxy = IOProxy.new(input, output, error)
@checkpointer = CheckpointerImpl.new(@io_proxy)
end