Lines Matching defs:events
39 private final BlockingQueue<Object> events = new LinkedBlockingQueue<>();
58 events.add(event);
63 events.add(new Ping(buffer));
67 events.add(new Pong(buffer));
71 events.add(new Close(code, reason));
75 events.add(e);
80 Object event = events.poll(10, TimeUnit.SECONDS);
144 assertTrue("Remaining events: " + events, events.isEmpty());
