basic.ForkPull Class Reference

Use the Fork processor to replicate input events in multiple output streams. More...

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

Detailed Description

Use the Fork processor to replicate input events in multiple output streams.

Graphically, the processors of this example can be drawn as follows:

The expected output of this program is:

P0 foo
P1 foo
P2 foo
P0 bar
P1 bar
P2 bar

Author

Sylvain Hallé Easy

Definition at line 44 of file ForkPull.java.

Member Function Documentation

main()

static void basic.ForkPull.main ( String []  args ) throws InterruptedException

static

Create a queue source with a few numbers

Definition at line 46 of file ForkPull.java.

    {
        /// Create a queue source with a few numbers
        QueueSource source = new QueueSource().setEvents(1, 2, 3, 4, 5);
        
        /* We create a fork processor that will replicate each input event
         * in two output streams. The "2" passed as an argument to the fork's
         * constructor signifies this. Then we connect the source to the
         * fork's input pipe. */
        Fork fork = new Fork(2);
        Connector.connect(source, fork);
        
        /* We get Pullables on both outputs of the fork. */
        Pullable p0 = fork.getPullableOutput(0);
        Pullable p1 = fork.getPullableOutput(1);
        
        /* Let's now pull an event from p0. The output is 1. */
        System.out.println("Output from p0: " + p0.pull());
        
        /* Let's now pull an event from p1. Surprisingly, the output is 1.
         * This can be explained by the fact that each input event in the
         * fork is replicated to all its output pipes. The fact that we
         * pulled an event from p0 has no effect on p1, and vice versa. */
        System.out.println("Output from p1: " + p1.pull());
        ///
        
        /* The independence between the fork's two outputs is further
         * illustrated by this sequence of calls. Notice how each pullable
         * moves through the input stream independently of calls to the
         * other pullable. */
        //*
        System.out.println("Output from p0: " + p0.pull());
        System.out.println("Output from p0: " + p0.pull());
        System.out.println("Output from p1: " + p1.pull());
        System.out.println("Output from p0: " + p0.pull());
        System.out.println("Output from p1: " + p1.pull());
        //*
    }

---

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

• Source/src/basic/ForkPull.java