Searched refs:checkState (Results 1 – 1 of 1) sorted by relevance
115 if (checkState(State.SHOULD_STOP_CONSUMING)) { in consume()123 while (checkState(State.CONSUMING)) { in consume()131 if (checkState(State.SHOULD_STOP_CONSUMING)) { in consume()154 while (checkState(State.WAITING)) { in run()165 if (checkState(State.FINISHED)) { in run()171 if (!(checkState(State.CONSUMING) || checkState(State.SHOULD_STOP_CONSUMING))) { in run()182 private synchronized boolean checkState(State expectedState) { in checkState() method in StreamConsumer