DataSource.java

/**
 * Main interface for accessing data. It extends EventListener to receive
 * incoming events from a remote data source. In this case, a chat server.
 */
public interface DataSource extends EventListener {

    void connect(String username) throws URISyntaxException;

    void disconnect();

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