import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;
import java.util.concurrent.CountDownLatch;

import static org.junit.Assert.assertEquals;

public class PingRemoteProcess implements Action<WorkerProcessContext>, Serializable, TestListenerInterface {
    CountDownLatch stopReceived;
    int count;

    public void send(String message, int count) {
        assertEquals(this.count, count);

        then:
        1 * listenerMock.send("message 2", 2)
        0 * listenerMock._
    }

    def thisProcessCanSendEventsToWorkerProcess() {
        when:
        execute(worker(new PingRemoteProcess()).onServer { objectConnection ->
            TestListenerInterface listener = objectConnection.addOutgoing(TestListenerInterface.class)
            listener.send("1", 0)
            listener.send("1", 1)