     """
 
     Observer.configure(pid, [{NoopPlugin, {"file:///", bmf}},{Take, 2}])
+    TestListener.clear(listener)
     :ok = Observer.run(pid)
 
     wait_for fn -> length(TestListener.get(listener)) >= 3 end

    GenStage.sync_subscribe(listener, to: Baumeister.EventCenter)
    {:ok, pid} = Observer.start_link(context[:test])
    assert is_pid(pid)

    # merge this with the context
    [pid: pid, listener: listener]

    command: echo "Ja, wir schaffen das"
    """

    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.
