basic.BinaryPush Class Reference

Push events into a processor of input arity 2. More...

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

Detailed Description

Push events into a processor of input arity 2.

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

The expected output of this program is:

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

See also

PipingUnaryPush

Author

Sylvain Hallé Easy

Definition at line 40 of file BinaryPush.java.

Member Function Documentation

main()

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

static

We create an instance of the adder processor

Definition at line 42 of file BinaryPush.java.

    {
        /// We create an instance of the adder processor
        Adder add = new Adder();
        
        // We then create a Print processor, which prints its input
        // to the console
        Print print = new Print().setSeparator("\n");
        
        // We connect the output of add to the input of print
        Connector.connect(add, print);
        
        // We now get a hold of the adder's pushables. Since add is of input
        // arity 2, it has two such pushables, numbered 0 and 1. Notice how
        // we use a different version of getPushableInput, which takes an
        // integer as an argument
        Pushable p0 = add.getPushableInput(0);
        Pushable p1 = add.getPushableInput(1);
        ///
        
        //* Let us push an event into p0. Nothing is printed, as the Adder
        // requires one event on each of its input pipes to do something.
        p0.push(3);
        System.out.println("This is the first printed line");
        
        // Let us push an event into p1. Since an event was ready to be
        // consumed at p0, adder can proceed with the addition and push its
        // result to print.
        p1.push(1);
        
        // We now push two events in a row to p1. As above, nothing is printed
        p1.push(4);
        p1.push(1);
        System.out.println("This is the third printed line");
        
        // We push two events to p0. Since events in p1 are ready to be
        // consumed, each push on p0 triggers the evaluation of a new addition
        p0.push(5);
        p0.push(9);
        //*
    }

---

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

• Source/src/basic/BinaryPush.java