Class UDPReceive
- java.lang.Object
-
- java.lang.Thread
-
- org.example.model.communication.server.UDPReceive
-
- All Implemented Interfaces:
java.lang.Runnable,CustomObservable<java.util.List<ConnectedUser>>
public class UDPReceive extends java.lang.Thread implements java.lang.Runnable, CustomObservable<java.util.List<ConnectedUser>>
-
-
Constructor Summary
Constructors Constructor Description UDPReceive()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetM_state()booleanisOpen()static voidmain(java.lang.String[] arg)voidnotifyAllSubscribers(java.util.List<ConnectedUser> c)voidrun()voidsetM_state(int state)voidsetOpen(boolean open)intsubscribe(CustomObserver<java.util.List<ConnectedUser>> o)CustomObserver<java.util.List<ConnectedUser>>unsubscribe(int i)-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Method Detail
-
isOpen
public boolean isOpen()
-
setOpen
public void setOpen(boolean open)
-
getM_state
public int getM_state()
-
setM_state
public void setM_state(int state)
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
main
public static void main(java.lang.String[] arg) throws java.io.IOException- Throws:
java.io.IOException
-
notifyAllSubscribers
public void notifyAllSubscribers(java.util.List<ConnectedUser> c)
-
subscribe
public int subscribe(CustomObserver<java.util.List<ConnectedUser>> o)
- Specified by:
subscribein interfaceCustomObservable<java.util.List<ConnectedUser>>
-
unsubscribe
public CustomObserver<java.util.List<ConnectedUser>> unsubscribe(int i)
- Specified by:
unsubscribein interfaceCustomObservable<java.util.List<ConnectedUser>>
-
-