basic.PipingUnary Class Reference

Pipe processors together using the Connector object. More...

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

Detailed Description

Pipe processors together using the Connector object.

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

See also

PipingBinary

Author

Sylvain Hallé Easy

Definition at line 36 of file PipingUnary.java.

Member Function Documentation

main()

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

static

Create a source of arbitrary numbers

Definition at line 38 of file PipingUnary.java.

    {
        /// Create a source of arbitrary numbers
        QueueSource source = new QueueSource();
        source.setEvents(1, 2, 3, 4, 5, 6);
        
        /* Create an instance of the Doubler processor (which is defined just
         * below in this file. */
        Doubler doubler = new Doubler();
        
        /* We now want to connect the output of source to the input of doubler.
         * This connection is done by using static method connect() of the
         * Connector object. Here, source has only one output stream, and
         * doubler has only one input stream. Therefore, we can simply call
         * connect() by giving the "upstream" processor first, and the
         * "downstream" processor second. The Connector will know that it needs
         * to connect the (only) output of source to the (only) input of
         * doubler. */
        Connector.connect(source, doubler);
        
        /* Let us now print what we receive by pulling on the output of
         * doubler. */
        Pullable p = doubler.getPullableOutput();
        for (int i = 0; i < 8; i++)
        {
            int x = (Integer) p.pull();
            System.out.println("The event is: " + x);
            // Sleep a little so you have time to read
            UtilityMethods.pause(1000);
        }
        ///
    }

---

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

• Source/src/basic/PipingUnary.java