Searched refs:changeState (Results 1 – 1 of 1) sorted by relevance
70 changeState(State.CONSUMING, State.WAITING); in giveStreamAndStartConsuming()80 changeState(State.SHOULD_STOP_CONSUMING, State.CONSUMING); in processFinished()106 changeState(State.FINISHED, State.WAITING); in shutdown()132 changeState(State.WAITING, State.SHOULD_STOP_CONSUMING); in consume()186 private synchronized void changeState(State newState, State previousState) { in changeState() method in StreamConsumer