|
@@ -94,11 +94,15 @@ public func websocket(
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- do {
|
|
|
|
|
|
|
+ func read() throws {
|
|
|
while true {
|
|
while true {
|
|
|
let frame = try session.readFrame()
|
|
let frame = try session.readFrame()
|
|
|
try handleOperationCode(frame)
|
|
try handleOperationCode(frame)
|
|
|
}
|
|
}
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ do {
|
|
|
|
|
+ try read()
|
|
|
} catch let error {
|
|
} catch let error {
|
|
|
switch error {
|
|
switch error {
|
|
|
case WebSocketSession.Control.close:
|
|
case WebSocketSession.Control.close:
|