- fix syntax

spec/inputs/redis.rb

@@ -1,31 +1,31 @@
 require "test_utils"
 require "redis"
 
-describe "inputs/redis" do
-  extend LogStash::RSpec
-
-  populate = proc do |key, event_count|
-    require "logstash/event"
-    redis = Redis.new(:host => "localhost")
-    event_count.times do |value|
-      event = LogStash::Event.new("@fields" => { "sequence" => value })
-      Stud::try(10.times) do
-        redis.rpush(key, event.to_json)
-      end
+def populate(key, event_count)
+  require "logstash/event"
+  redis = Redis.new(:host => "localhost")
+  event_count.times do |value|
+    event = LogStash::Event.new("@fields" => { "sequence" => value })
+    Stud::try(10.times) do
+      redis.rpush(key, event.to_json)
     end
   end
+end
 
-  process = proc do |plugins, event_count|
-    sequence = 0
-    redis = plugins.first
-    output = Shiftback.new do |event|
-      insist { event["sequence"] } == sequence
-      sequence += 1
-      redis.teardown if sequence == event_count
-    end
-    redis.register
-    redis.run(output)
-  end # process
+def process(plugins, event_count)
+  sequence = 0
+  redis = plugins.first
+  output = Shiftback.new do |event|
+    insist { event["sequence"] } == sequence
+    sequence += 1
+    redis.teardown if sequence == event_count
+  end
+  redis.register
+  redis.run(output)
+end # process
+
+describe "inputs/redis" do
+  extend LogStash::RSpec
 
   describe "read events from a list" do
     key = 10.times.collect { rand(10).to_s }.join("")