20 21 22 23
# File 'lib/fluent/pipeline.rb', line 20 def via(method_name) self.pipe_method = method_name self end