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

return event user

Browse Source
This commit is contained in:
Salvatore Giordano
2021-07-02 15:56:14 +02:00
parent 0e6acd59b6
commit 1dc23583a6
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/stream_chat/lib/src/client/client.dart
+4 -4
View File
@@ -319,8 +319,8 @@ class StreamChatClient {
_chatPersistenceClient = _originalChatPersistenceClient; _chatPersistenceClient = _originalChatPersistenceClient;
await _chatPersistenceClient!.connect(ownUser.id); await _chatPersistenceClient!.connect(ownUser.id);
} }
final event = await openConnection(); final res = await openConnection();
return event; return res;
} catch (e, stk) { } catch (e, stk) {
if (e is StreamWebSocketError && e.isRetriable) { if (e is StreamWebSocketError && e.isRetriable) {
final event = await _chatPersistenceClient?.getConnectionInfo(); final event = await _chatPersistenceClient?.getConnectionInfo();
@@ -362,8 +362,8 @@ class StreamChatClient {
_ws.connectionStatusStream.skip(1).listen(_connectionStatusHandler); _ws.connectionStatusStream.skip(1).listen(_connectionStatusHandler);
try { try {
await _ws.connect(user); final event = await _ws.connect(user);
return state.user!; return event.me!.merge(user);
} catch (e, stk) { } catch (e, stk) {
logger.severe('error connecting ws', e, stk); logger.severe('error connecting ws', e, stk);
rethrow; rethrow;