com.jenjinstudios.io.server

Class Server<T extends ExecutionContext>

java.lang.Object

com.jenjinstudios.io.server.Server<T>

public class Server<T extends ExecutionContext>
extends java.lang.Object

Used to accept and manage incoming connections.

Method Summary

Modifier and Type	Method and Description
void	broadcast(Message message) Broadcast the given message to all connections.
int	broadcast(Message message, java.util.function.Predicate<Connection> predicate) Broadcast a message to all connections that fulfill the given predicate.
int	getConnectionCount()
void	start() Start listening for inbound connections.
void	stop() Stop listening for inbound connections and attempt to gracefully close all existing connections.

Methods inherited from class java.lang.Object

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

Method Detail

stop

public void stop()

Stop listening for inbound connections and attempt to gracefully close all existing connections.

start

public void start()

Start listening for inbound connections.

broadcast

public void broadcast(Message message)

Broadcast the given message to all connections.

Parameters:

message - The message to be broadcast.

broadcast

public int broadcast(Message message,
                     java.util.function.Predicate<Connection> predicate)

Broadcast a message to all connections that fulfill the given predicate.

Parameters:

message - The message to be broadcast.

predicate - The predicate which, if fulfilled, will cause a message to be broadcast by the given connection.

Returns:

The number of Connections to which the message was broadcast.

getConnectionCount

public int getConnectionCount()