in business-model/src/main/java/com/google/cloud/orderbook/QueuedProducer.java [128:132]
public boolean hasNext() {
// More work to do *or* we're not yet finalised and shutdown work
// to be done.
return !que.isEmpty() || !state.equals(State.FINALISED);
}