     command: echo "Ja, wir schaffen das"
     """
 
-    Observer.configure(pid, [{NoopPlugin, {"file:///", bmf}}])
+    Observer.configure(pid, [{NoopPlugin, {"file:///", bmf}}, {Delay, 50}])
+    TestListener.clear(listener)
     :ok = Observer.run(pid)
 
     wait_for fn -> length(TestListener.get(listener)) >= 2 end
+    Observer.stop(pid, :stop)
 
     # take only the first two elements, since noop is extremely fast
     # and produces a huge amount of events.


  alias Baumeister.Test.TestListener
  alias Experimental.GenStage

  alias Baumeister.Observer
  alias Baumeister.Observer.FailPlugin
  alias Baumeister.Observer.NoopPlugin
  alias Baumeister.Observer.Take

  def wait_for(pred) do
    case pred.() do

    """

    Observer.configure(pid, [{Take, 0}, {NoopPlugin, {"file:///", bmf}}])

    :ok = Observer.run(pid)

    wait_for fn -> length(TestListener.get(listener)) >= 3 end
