talksik/stream-chat-flutter
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix analyze

Browse Source
This commit is contained in:
Salvatore Giordano
2021-06-09 16:28:05 +02:00
parent dc6c3094e9
commit 23fed8d35f
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat_flutter/lib/src/message_list_view.dart
+7 -6
View File
@@ -1110,7 +1110,7 @@ class _MessageListViewState extends State<MessageListView> {
_itemPositionListener = _itemPositionListener =
widget.itemPositionListener ?? ItemPositionsListener.create(); widget.itemPositionListener ?? ItemPositionsListener.create();
_itemPositionStream = _itemPositionStream =
valueListenableToStreamAdapter(_itemPositionListener.itemPositions); _valueListenableToStreamAdapter(_itemPositionListener.itemPositions);
_getOnThreadTap(); _getOnThreadTap();
super.initState(); super.initState();
@@ -1241,11 +1241,12 @@ class _LoadingIndicator extends StatelessWidget {
} }
} }
Stream<T> valueListenableToStreamAdapter<T>(ValueListenable<T> listenable) { Stream<T> _valueListenableToStreamAdapter<T>(ValueListenable<T> listenable) {
late StreamController<T> controller; // ignore: close_sinks
late StreamController<T> _controller;
void listener() { void listener() {
controller.add(listenable.value); _controller.add(listenable.value);
} }
void start() { void start() {
@@ -1256,12 +1257,12 @@ Stream<T> valueListenableToStreamAdapter<T>(ValueListenable<T> listenable) {
listenable.removeListener(listener); listenable.removeListener(listener);
} }
controller = StreamController<T>( _controller = StreamController<T>(
onListen: start, onListen: start,
onPause: end, onPause: end,
onResume: start, onResume: start,
onCancel: end, onCancel: end,
); );
return controller.stream; return _controller.stream;
} }