Code Examples
A repository of 155 code examples for BeepBeep
PullHard.java
1 /*
2  BeepBeep, an event stream processor
3  Copyright (C) 2008-2018 Sylvain HallĂ©
4 
5  This program is free software: you can redistribute it and/or modify
6  it under the terms of the GNU Lesser General Public License as published
7  by the Free Software Foundation, either version 3 of the License, or
8  (at your option) any later version.
9 
10  This program is distributed in the hope that it will be useful,
11  but WITHOUT ANY WARRANTY; without even the implied warranty of
12  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13  GNU Lesser General Public License for more details.
14 
15  You should have received a copy of the GNU Lesser General Public License
16  along with this program. If not, see <http://www.gnu.org/licenses/>.
17  */
18 package basic;
19 
20 import ca.uqac.lif.cep.Connector;
21 import ca.uqac.lif.cep.Pullable;
22 import ca.uqac.lif.cep.tmf.CountDecimate;
23 import ca.uqac.lif.cep.tmf.QueueSource;
24 
25 /**
26  * Illustration of the difference between using
27  * {@link ca.uqac.lif.cep.Pullable#pull() pull()} and
28  * {@link ca.uqac.lif.cep.Pullable#pullSoft() pullSoft()} on a
29  * {@link ca.uqac.lif.cep.Pullable Pullable} object.
30  * In this example, we use the "hard" (or standard) way of fetching
31  * objects from a Pullable.
32  *
33  * @author Sylvain HallĂ©
34  * @see PullSoft
35  */
36 public class PullHard
37 {
38  public static void main(String[] args)
39  {
40  ///
41  QueueSource source = new QueueSource().loop(false);
42  source.setEvents(0, 1, 2, 3);
43  CountDecimate decim = new CountDecimate(2);
44  Connector.connect(source, decim);
45  Pullable p = decim.getPullableOutput();
46  ///
47  //!
48  for (int i = 0; i < 5; i++)
49  {
50  boolean b = p.hasNext();
51  System.out.println(b);
52  if (b == true)
53  {
54  System.out.println(p.pull());
55  }
56  }
57  //!
58  }
59 }
Illustration of the difference between using pull() and pullSoft() on a Pullable object.
Definition: PullHard.java:36
static void main(String[] args)
Definition: PullHard.java:38