io.LineReaderExample Class Reference

Read lines from a text file and convert them into numbers. More...

Static Public Member Functions
static void	main (String[] args)

Detailed Description

Read lines from a text file and convert them into numbers.

This illustrates the use of the ReadLines processor.

The expected output of the program is:

3,Integer
1,Integer
4,Integer
1,Integer
5,Integer
9,Integer
2.2,Float
Exception in thread "main" java.util.NoSuchElementException
    at ca.uqac.lif.cep.UniformProcessor$UnaryPullable.pull(UniformProcessor.java:269)
    at io.LineReaderExample.main(LineReaderExample.java:43)

Author

Sylvain Hallé Easy

Definition at line 48 of file LineReaderExample.java.

Member Function Documentation

main()

static void io.LineReaderExample.main ( String []  args )

static

We obtain an InputStream from a file. Since we refer to a file

Definition at line 50 of file LineReaderExample.java.

    {
        /// We obtain an InputStream from a file. Since we refer to a file
        // that lies within the source code's folders, we can access it using
        // the getResourceAsStream method. You could replace this with any
        // other instruction that returns an InputStream.
        InputStream is = LineReaderExample.class.getResourceAsStream("pi.txt");
        
        // We then instantiate a ReadLines processor, and instruct it to read
        // from the input stream we created
        ReadLines reader = new ReadLines(is);
        
        // The output of ReadLines are String events. We apply the function
        // NumberCast on these strings to convert them into number objects.
        ApplyFunction cast = new ApplyFunction(Numbers.numberCast);
        
        // The reader and cast processors are connected
        Connector.connect(reader, cast);
        
        // We then pull repeatedly on cast. Note the use of hasNext: since we
        // are reading from a file, eventually we reach the end of the file
        // and no more events can be produced.
        Pullable p = cast.getPullableOutput();
        while (p.hasNext())
        {
            Number n = (Number) p.next();
            System.out.println(n + "," + n.getClass().getSimpleName());
        }
        // Just for fun, let us try to pull one last time on p. This will
        // throw an exception
        p.pull();
        ///
    }

---

The documentation for this class was generated from the following file:

• Source/src/io/LineReaderExample.java