Class FlightEndpointDataQueue

All Implemented Interfaces:

public class FlightEndpointDataQueue extends Object implements AutoCloseable
Auxiliary class used to handle consuming of multiple FlightStream.

The usage follows this routine:

  1. Create a FlightStreamQueue;
  2. Call enqueue(FlightStream) for all streams to be consumed;
  3. Call next() to get a FlightStream that is ready to consume
  4. Consume the given FlightStream and add it back to the queue - call enqueue(FlightStream)
  5. Repeat from (3) until next() returns null.