Project

General

Profile

1 26600 sandro.lab
package eu.dnetlib.msro.workflows.util;
2
3
import javax.xml.ws.wsaddressing.W3CEndpointReference;
4
5
import eu.dnetlib.enabling.resultset.ResultSetFactory;
6
import eu.dnetlib.msro.workflows.resultset.ProcessCountingResultSetListener;
7
8
public class ResultsetProgressProvider implements ProgressProvider {
9
10
	private W3CEndpointReference epr;
11
	private ProcessCountingResultSetListener listener;
12
13
	public ResultsetProgressProvider(ResultSetFactory resultSetFactory,	ProcessCountingResultSetListener listener) {
14
		super();
15
		this.epr = resultSetFactory.createResultSet(listener);
16
		this.listener = listener;
17
	}
18
19
	@Override
20
	public int getTotalValue() {
21
		return listener.getSize();
22
	}
23
24
	@Override
25
	public int getCurrentValue() {
26
		return listener.getCount();
27
	}
28
29
	@Override
30
	public boolean isInaccurate() {
31
		return listener.isInaccurate();
32
	}
33
34
	public W3CEndpointReference getEpr() {
35
		return epr;
36
	}
37
38
	public void setEpr(W3CEndpointReference epr) {
39
		this.epr = epr;
40
	}
41
42
	public ProcessCountingResultSetListener getListener() {
43
		return listener;
44
	}
45
46
	public void setListener(ProcessCountingResultSetListener listener) {
47
		this.listener = listener;
48
	}
49
50
}