EventService.java

/**
 * Service layer that connects/disconnects to the server and
 * sends and receives events too.
 */
public interface EventService {

    void connect(String username) throws URISyntaxException;

    void disconnect();

    Flowable<ChatMessage> sendMessage(ChatMessage chatMessage);
  
    void setEventListener(EventListener eventListener);
}