net.tomp2p.task
Class AsyncTask

java.lang.Object
  net.tomp2p.task.AsyncTask

All Implemented Interfaces:

TaskResultListener

public class AsyncTask
extends Object
implements TaskResultListener

Constructor Summary

AsyncTask(TaskRPC taskRPC, Scheduler scheduler, PeerBean peerBean)

Method Summary

FutureAsyncTask	submit(PeerAddress remotePeer, ChannelCreator channelCreator, Number160 taskId, Map<Number160,Data> dataMap, Worker mapper, boolean forceUDP, boolean sign)
void	taskFailed(Number320 taskKey)
void	taskReceived(Number320 taskKey, Map<Number160,Data> dataMap)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncTask

public AsyncTask(TaskRPC taskRPC,
                 Scheduler scheduler,
                 PeerBean peerBean)

Method Detail

submit

public FutureAsyncTask submit(PeerAddress remotePeer,
                              ChannelCreator channelCreator,
                              Number160 taskId,
                              Map<Number160,Data> dataMap,
                              Worker mapper,
                              boolean forceUDP,
                              boolean sign)

taskReceived

public void taskReceived(Number320 taskKey,
                         Map<Number160,Data> dataMap)

Specified by:

taskReceived in interface TaskResultListener

taskFailed

public void taskFailed(Number320 taskKey)

Specified by:

taskFailed in interface TaskResultListener