Changed the LxState of your data and triggers all the listeners
void setState(LxState lxState) { if (!stateObserver.isClosed) { this._state = lxState; this.stateObserver.sink.add(this._state!); } }