code: public DataInputView getReadEndAfterSuperstepEnded() {
  		try {
  			return queue.take().switchBuffers();
  		} catch (InterruptedException e) {
  			throw new RuntimeException(e);
  		} catch (IOException e) {
  			throw new RuntimeException(e);
  		}
  	}
docs: Called by iteration head after it has sent all input for the current superstep through the data channel
  (blocks iteration head).