src/test/java/com/fivetran/javac/ResponseCollector.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

package com.fivetran.javac;

import com.fivetran.javac.message.Response;
import com.fivetran.javac.message.ResponseChannel;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

public class ResponseCollector implements ResponseChannel {
    public final List<Response> responses = new ArrayList<>();

    @Override
    public void next(Response response) throws IOException {
        responses.add(response);
    }
}