|
|
|
|
|
|
|
|
* |
|
|
* |
|
|
* @author ahren |
|
|
* @author ahren |
|
|
*/ |
|
|
*/ |
|
|
public abstract class Transmitter implements Runnable, Subscriber<Figur> { |
|
|
|
|
|
|
|
|
public abstract class Transmitter implements Runnable { |
|
|
|
|
|
|
|
|
static final int timeout = 60000; |
|
|
static final int timeout = 60000; |
|
|
private static final int PORT = 35000; |
|
|
private static final int PORT = 35000; |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public void onSubscribe(Flow.Subscription subscription) { |
|
|
|
|
|
throw new UnsupportedOperationException("Not supported yet."); // Generated from nbfs://nbhost/SystemFileSystem/Templates/Classes/Code/GeneratedMethodBody |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public void onNext(Figur item) { |
|
|
|
|
|
throw new UnsupportedOperationException("Not supported yet."); // Generated from nbfs://nbhost/SystemFileSystem/Templates/Classes/Code/GeneratedMethodBody |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public void onError(Throwable throwable) { |
|
|
|
|
|
throw new UnsupportedOperationException("Not supported yet."); // Generated from nbfs://nbhost/SystemFileSystem/Templates/Classes/Code/GeneratedMethodBody |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public void onComplete() { |
|
|
|
|
|
throw new UnsupportedOperationException("Not supported yet."); // Generated from nbfs://nbhost/SystemFileSystem/Templates/Classes/Code/GeneratedMethodBody |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void startempfangen() |
|
|
|
|
|
|
|
|
private void startempfangen() |
|
|
{ |
|
|
{ |
|
|
synchronized (this){ |
|
|
synchronized (this){ |
|
|
} |
|
|
} |