val observable = filterListDataManager.getFilteredRfiListStream(viewerStateManager.getActiveFileUrn(), activeFile.await()) val channel = observable.openSubscription() val listRfi: List = channel.receive()