AdmiinX

import org.junit.Test;
import java.util.concurrent.TimeUnit;

import rx.Observable;
import rx.observers.TestSubscriber;

public class RxJavaTest{
    @Test
    public void testConcatenating(){
        Observable<String> first = Observable.just("first").delay(1,TimeUnit.SECONDS);

AdmiinX

//============================================================================
// Task        : Compiler
// Description : Lexical Analyzer
// Name		   : Mahmoud Mohamed Fathy
// ID		   : 2012030135
//============================================================================

#include <iostream>
#include <fstream>
#include <string>