@@ -7,19 +7,12 @@ import 'package:mineral/src/infrastructure/services/wss/websocket_requested_mess
77
88abstract interface class WebsocketClient {
99 String get name;
10-
1110 String get url;
12-
1311 Stream ? get stream;
14-
1512 Interceptor get interceptor;
16-
1713 Future <void > connect ();
18-
1914 void disconnect ({int ? code, String ? reason});
20-
2115 Future <void > send (String message);
22-
2316 Future <void > listen (void Function (WebsocketMessage ) callback);
2417}
2518
@@ -43,13 +36,13 @@ final class WebsocketClientImpl implements WebsocketClient {
4336 @override
4437 Stream ? stream;
4538
46- WebsocketClientImpl (
47- { required this .url,
48- this .name = 'default' ,
49- void Function (Object payload)? onError,
50- void Function (int ? exitCode)? onClose,
51- void Function (WebsocketMessage )? onOpen})
52- : _onError = onError,
39+ WebsocketClientImpl ({
40+ required this .url,
41+ this .name = 'default' ,
42+ void Function (Object payload)? onError,
43+ void Function (int ? exitCode)? onClose,
44+ void Function (WebsocketMessage )? onOpen,
45+ }) : _onError = onError,
5346 _onClose = onClose,
5447 _onOpen = onOpen;
5548
@@ -103,18 +96,21 @@ final class WebsocketClientImpl implements WebsocketClient {
10396
10497 Future <void > _handleMessage (callback, dynamic message) async {
10598 final interceptedMessage = await _handleMessageInterceptors (
106- WebsocketMessageImpl (
107- channelName: name,
108- originalContent: message,
109- content: message));
99+ WebsocketMessageImpl (
100+ channelName: name,
101+ originalContent: message,
102+ content: message,
103+ ),
104+ );
110105
111106 callback (interceptedMessage);
112107 }
113108
114109 @override
115110 Future <void > send (String message) async {
116111 final interceptedMessage = await _handleRequestedMessageInterceptors (
117- WebsocketRequestedMessageImpl (channelName: name, content: message));
112+ WebsocketRequestedMessageImpl (channelName: name, content: message),
113+ );
118114
119115 switch (_channel? .readyState) {
120116 case io.WebSocket .open:
@@ -125,7 +121,8 @@ final class WebsocketClientImpl implements WebsocketClient {
125121 }
126122
127123 Future <WebsocketMessage > _handleMessageInterceptors (
128- WebsocketMessage message) async {
124+ WebsocketMessage message,
125+ ) async {
129126 for (final interceptor in interceptor.message) {
130127 message = await interceptor (message);
131128 }
@@ -134,7 +131,8 @@ final class WebsocketClientImpl implements WebsocketClient {
134131 }
135132
136133 Future <WebsocketRequestedMessage > _handleRequestedMessageInterceptors (
137- WebsocketRequestedMessage message) async {
134+ WebsocketRequestedMessage message,
135+ ) async {
138136 for (final interceptor in interceptor.request) {
139137 message = await interceptor (message);
140138 }
0 commit comments