RemoteDataSource.java

/**
 * Remote data source.
 *
 */
public class RemoteDataSource implements DataSource {

    private static RemoteDataSource INSTANCE;
    private static EventService mEventService = EventServiceImpl.getInstance();
    private EventListener mRepoEventListener;

    private RemoteDataSource() {
        mEventService.setEventListener(this);
    }

    public static RemoteDataSource getInstance() {
        if (INSTANCE == null) {
            INSTANCE = new RemoteDataSource();
        }

        return INSTANCE;
    }

    @Override
    public void setEventListener(EventListener eventListener) {
        mRepoEventListener = eventListener;
    }
    
    @Override
    public void connect(String username) throws URISyntaxException {
        mEventService.connect(username);
    }

    @Override
    public void disconnect() {
        mEventService.disconnect();
    }
    
    @Override
    public void onConnect(Object... args) {
        if (mRepoEventListener != null)
            mRepoEventListener.onConnect(args);
    }

    @Override
    public void onDisconnect(Object... args) {
        if (mRepoEventListener != null)
            mRepoEventListener.onDisconnect(args);
    }

    @Override
    public void onNewMessage(Object... args) {
        if (mRepoEventListener != null)
            mRepoEventListener.onNewMessage(args);
    }

    @Override
    public Flowable<ChatMessage> sendMessage(ChatMessage chatMessage) {
        return mEventService.sendMessage(chatMessage);
    }
}