如何在Lagom中测试读取端处理器？

import akka.Done;
import com.lightbend.lagom.javadsl.testkit.ServiceTest;
import com.lightbend.lagom.javadsl.testkit.TestEventStream;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;

import static org.junit.Assert.assertEquals;

public class MyProcessorTest {

    private static ServiceTest.TestServer server;

    @BeforeClass
    public static void setUp() {
        server = ServiceTest.startServer(ServiceTest.defaultSetup());
    }

    @AfterClass
    public static void tearDown() {
        server.stop();
    }

    @Test
    public void testProcessor() {
        // 模拟事件流
        TestEventStream<SomeEvent> eventStream = server.injector().instanceOf(TestEventStream.class);
        eventStream.publish(new SomeEvent("event1"));
        eventStream.publish(new SomeEvent("event2"));

        // 创建读取端处理器实例
        MyProcessor processor = server.injector().instanceOf(MyProcessor.class);

        // 调用处理方法
        Done result = processor.handle(eventStream);

        // 验证结果
        assertEquals(Done.getInstance(), result);
        assertEquals(2, processor.getProcessedEvents().size());
    }
}