basic.PipingUnaryPush 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:

This example works like PipingBinary, except that it operates in push mode instead of pull mode.

The expected output of this program is:

0,2,4,6,8,10,12,14,

See also

PipingBinary

Author

Sylvain Hallé Easy

Definition at line 44 of file PipingUnaryPush.java.

Member Function Documentation

main()

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

static

Create an instance of the Doubler processor.

Definition at line 46 of file PipingUnaryPush.java.

    {   
        /// Create an instance of the Doubler processor.
        Doubler doubler = new Doubler();
        
        /* Create a processor that simply prints to the console every event
         * it receives */
        Print print = new Print();
        
        /* We now want to connect the output of doubler to the input of print.
         * This connection is done by using static method connect() of the
         * Connector object. */
        Connector.connect(doubler, print);
        
        /* Let us now push events to the doubler. */
        Pushable p = doubler.getPushableInput();
        for (int i = 0; i < 8; i++)
        {
            p.push(i);
            // Sleep a little in between so you have time to read
            UtilityMethods.pause(1000);
        }
        ///
    }

---

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

• Source/src/basic/PipingUnaryPush.java