basic.SumTwo Class Reference

Use the Trim and Fork processors to compute the sum of two successive events. More...

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

Detailed Description

Use the Trim and Fork processors to compute the sum of two successive events.

The chain of processors in this example can be represented graphically as:

Author

Sylvain Hallé Easy

Definition at line 38 of file SumTwo.java.

Member Function Documentation

main()

static void basic.SumTwo.main ( String []  args )

static

Create a source of arbitrary numbers

Definition at line 40 of file SumTwo.java.

    {
        /// Create a source of arbitrary numbers
        QueueSource source = new QueueSource().setEvents(1, 2, 3, 4, 5, 6);
        
        // Fork the stream in two and connect it to the source
        Fork fork = new Fork(2);
        Connector.connect(source, fork);
        
        // Create an addition processor. Connect its first input to the
        // first output of the fork.
        ApplyFunction add = new ApplyFunction(Numbers.addition);
        Connector.connect(fork, 0, add, 0);
        
        /* Create an instance of the Trim processor. This processor is
         * instructed to discard the first 1 events it receives. Then
         * connect this to the second output of the fork, and to the
         * second input of add. */
        Trim trim = new Trim(1);
        Connector.connect(fork, 1, trim, 0);
        Connector.connect(trim, 0, add, 1);
        
        /* Let us now print what we receive by pulling on the output of
         * add. */
        Pullable p = add.getPullableOutput();
        for (int i = 0; i < 6; i++)
        {
            float x = (Float) p.pull();
            System.out.println("The event is: " + x);
        }
        ///
    }

---

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

• Source/src/basic/SumTwo.java