File tree Expand file tree Collapse file tree 1 file changed +4
-6
lines changed
Sources/StructuredWebSocketClient Expand file tree Collapse file tree 1 file changed +4
-6
lines changed Original file line number Diff line number Diff line change @@ -73,7 +73,7 @@ public final class URLSessionWebSocketTransport: MessageTransport {
73
73
// the connected event. If no one is consuming events yet, we will
74
74
// suspend until someone does.
75
75
// We should be able to do this in the initializer, as nobody consumes values anyway
76
- self . readNextMessage ( )
76
+ self . readNextMessage ( 1 )
77
77
}
78
78
79
79
private func onClose( closeCode: URLSessionWebSocketTask . CloseCode , reason: Data ? ) async {
@@ -101,7 +101,7 @@ public final class URLSessionWebSocketTransport: MessageTransport {
101
101
}
102
102
}
103
103
104
- private func readNextMessage( ) {
104
+ private func readNextMessage( _ number : Int ) {
105
105
guard wsTask. closeCode == . invalid else {
106
106
return
107
107
}
@@ -112,12 +112,10 @@ public final class URLSessionWebSocketTransport: MessageTransport {
112
112
return
113
113
}
114
114
do {
115
- var count = 1
116
115
let message = try result. get ( )
117
- let meta = MessageMetadata ( number: count )
116
+ let meta = MessageMetadata ( number: number )
118
117
await self ? . events. send ( . message( message, metadata: meta) )
119
- count += 1
120
- self ? . readNextMessage ( )
118
+ self ? . readNextMessage ( number + 1 )
121
119
} catch {
122
120
await self ? . events. send ( . failure( error) )
123
121
await self ? . onClose ( closeCode: . abnormalClosure, reason: Data ( error. localizedDescription. utf8) )
You can’t perform that action at this time.
0 commit comments