Source
void onProfileUpdated() { if (_ready) { if (request.streamStatus != StreamStatus.initialize) { _controller.add(new RequesterListUpdate( node, changes.toList(), request.streamStatus)); changes.clear(); } if (request.streamStatus == StreamStatus.closed) { _controller.close(); } } }