We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a662c7c commit a0316fdCopy full SHA for a0316fd
packages/graphql/lib/src/links/websocket_link/websocket_client.dart
@@ -636,8 +636,13 @@ class GraphQLWebSocketChannel extends StreamChannelMixin<dynamic>
636
Stream<GraphQLSocketMessage>? _messages;
637
638
/// Stream of messages from the endpoint parsed as GraphQLSocketMessages
639
- Stream<GraphQLSocketMessage> get messages => _messages ??=
640
- stream.map<GraphQLSocketMessage>(GraphQLSocketMessage.parse);
+ Stream<GraphQLSocketMessage> get messages {
+ if (_messages == null) _messages = stream.map((event) {
641
+ return GraphQLSocketMessage.parse(event);
642
+ }).asBroadcastStream();
643
+
644
+ return _messages!;
645
+ }
646
647
String? get protocol => _webSocket.protocol;
648
0 commit comments