basic.GroupSimple Class Reference

Encapsulate a chain of processors into a Group. More...

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

Detailed Description

Encapsulate a chain of processors into a Group.

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

See also

SumTwo

Author

Sylvain Hallé Easy GroupProcessor#associateInput(int, ca.uqac.lif.cep.Processor, int)

Definition at line 24 of file GroupSimple.java.

Member Function Documentation

main()

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

static

Create a source of arbitrary numbers

Definition at line 26 of file GroupSimple.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
        GroupProcessor group = new GroupProcessor(1, 1);
        {
            Fork fork = new Fork(2);
            ApplyFunction add = new ApplyFunction(Numbers.addition);
            Connector.connect(fork, 0, add, 0);
            Trim trim = new Trim(1);
            Connector.connect(fork, 1, trim, 0);
            Connector.connect(trim, 0, add, 1);
            group.addProcessors(fork, trim, add);
            group.associateInput(0, fork, 0);
            group.associateOutput(0, add, 0);
        }
        
        // Connect the source to the group
        Connector.connect(source, group);

        /* Let us now print what we receive by pulling on the output of
         * group. */
        Pullable p = group.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/GroupSimple.java