mirror of
https://github.com/haveno-dex/haveno.git
synced 2025-04-19 07:15:54 -04:00
Change generics as on Eclipse the prev. version did fail
This commit is contained in:
parent
da506226d9
commit
105a63847a
@ -21,7 +21,6 @@ import io.bitsquare.common.handlers.ErrorMessageHandler;
|
||||
import io.bitsquare.common.handlers.ResultHandler;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import java.util.Queue;
|
||||
import java.util.concurrent.LinkedBlockingQueue;
|
||||
|
||||
@ -33,7 +32,7 @@ public class TaskRunner<T extends Model> {
|
||||
|
||||
private final Queue<Class<? extends Task>> tasks = new LinkedBlockingQueue<>();
|
||||
protected final T sharedModel;
|
||||
private final Class<? extends Model> sharedModelClass;
|
||||
private final Class<T> sharedModelClass;
|
||||
private final ResultHandler resultHandler;
|
||||
private final ErrorMessageHandler errorMessageHandler;
|
||||
private boolean failed = false;
|
||||
@ -43,19 +42,18 @@ public class TaskRunner<T extends Model> {
|
||||
|
||||
|
||||
public TaskRunner(T sharedModel, ResultHandler resultHandler, ErrorMessageHandler errorMessageHandler) {
|
||||
this(sharedModel, sharedModel.getClass(), resultHandler, errorMessageHandler);
|
||||
this(sharedModel, (Class<T>) sharedModel.getClass(), resultHandler, errorMessageHandler);
|
||||
}
|
||||
|
||||
public TaskRunner(T sharedModel, Class<? extends Model> sharedModelClass, ResultHandler resultHandler, ErrorMessageHandler errorMessageHandler) {
|
||||
public TaskRunner(T sharedModel, Class<T> sharedModelClass, ResultHandler resultHandler, ErrorMessageHandler errorMessageHandler) {
|
||||
this.sharedModel = sharedModel;
|
||||
this.resultHandler = resultHandler;
|
||||
this.errorMessageHandler = errorMessageHandler;
|
||||
this.sharedModelClass = sharedModelClass;
|
||||
}
|
||||
|
||||
public final void addTasks(Class<? extends Task<? extends Model>>... items) {
|
||||
List<Class<? extends Task<? extends Model>>> list = Arrays.asList(items);
|
||||
tasks.addAll(list);
|
||||
public final void addTasks(Class<? extends Task<T>>... items) {
|
||||
tasks.addAll(Arrays.asList(items));
|
||||
}
|
||||
|
||||
public void run() {
|
||||
|
@ -19,18 +19,12 @@ package io.bitsquare.trade.protocol.trade;
|
||||
|
||||
import io.bitsquare.common.handlers.ErrorMessageHandler;
|
||||
import io.bitsquare.common.handlers.ResultHandler;
|
||||
import io.bitsquare.common.taskrunner.Model;
|
||||
import io.bitsquare.common.taskrunner.TaskRunner;
|
||||
import io.bitsquare.trade.Trade;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
public class TradeTaskRunner extends TaskRunner<Trade> {
|
||||
private static final Logger log = LoggerFactory.getLogger(TradeTaskRunner.class);
|
||||
|
||||
public TradeTaskRunner(Trade sharedModel, ResultHandler resultHandler, ErrorMessageHandler errorMessageHandler) {
|
||||
super(sharedModel, (Class<? extends Model>) sharedModel.getClass().getSuperclass().getSuperclass(), resultHandler, errorMessageHandler);
|
||||
super(sharedModel, (Class<Trade>) sharedModel.getClass().getSuperclass().getSuperclass(), resultHandler, errorMessageHandler);
|
||||
}
|
||||
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user