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 int
getM_state()
boolean
isOpen()
static void
main(java.lang.String[] arg)
void
notifyAllSubscribers(java.util.List<ConnectedUser> c)
void
run()
void
setM_state(int state)
void
setOpen(boolean open)
int
subscribe(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:
run
in interfacejava.lang.Runnable
- Overrides:
run
in 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:
subscribe
in interfaceCustomObservable<java.util.List<ConnectedUser>>
-
unsubscribe
public CustomObserver<java.util.List<ConnectedUser>> unsubscribe(int i)
- Specified by:
unsubscribe
in interfaceCustomObservable<java.util.List<ConnectedUser>>
-
-