package cs.bilkent.joker.engine.pipeline;
<BUG>import java.util.concurrent.Future;
import cs.bilkent.joker.operator.impl.TuplesImpl;
public interface DownstreamTupleSender
{
Future<Void> send ( TuplesImpl tuples );</BUG>
}

package cs.bilkent.joker.engine.pipeline;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import cs.bilkent.joker.operator.impl.TuplesImpl;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
public interface DownstreamTupleSender
{
long OFFER_TIMEOUT = 1;
TimeUnit OFFER_TIME_UNIT = MILLISECONDS;
Future<Void> send ( TuplesImpl tuples );
