diff options
| -rw-r--r-- | lib/dtas/sink.rb | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/dtas/sink.rb b/lib/dtas/sink.rb index 25831a4..b06e284 100644 --- a/lib/dtas/sink.rb +++ b/lib/dtas/sink.rb @@ -102,7 +102,7 @@ class DTAS::Sink # :nodoc: end @pid = dtas_spawn(format.to_env.merge!(@env), cmd, opts) - inputs.each_value { |rpipe| rpipe.close } + inputs.each_value(&:close) rv end |