File tree 5 files changed +11
-11
lines changed
Tests/GraphQLWSTests/Utils
5 files changed +11
-11
lines changed Original file line number Diff line number Diff line change @@ -27,12 +27,12 @@ import GraphQLWS
27
27
/// Messenger wrapper for WebSockets
28
28
class WebSocketMessenger : Messenger {
29
29
private weak var websocket: WebSocket?
30
- private var onRecieve : (String ) -> Void = { _ in }
30
+ private var onReceive : (String ) -> Void = { _ in }
31
31
32
32
init (websocket : WebSocket) {
33
33
self .websocket = websocket
34
34
websocket.onText { _ , message in
35
- self .onRecieve (message)
35
+ self .onReceive (message)
36
36
}
37
37
}
38
38
@@ -41,8 +41,8 @@ class WebSocketMessenger: Messenger {
41
41
websocket.send (message)
42
42
}
43
43
44
- func onRecieve (callback : @escaping (String ) -> Void ) {
45
- self .onRecieve = callback
44
+ func onReceive (callback : @escaping (String ) -> Void ) {
45
+ self .onReceive = callback
46
46
}
47
47
48
48
func error (_ message : String , code : Int ) {
Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ public class Client<InitPayload: Equatable & Codable> {
27
27
messenger: Messenger
28
28
) {
29
29
self . messenger = messenger
30
- messenger. onRecieve { message in
30
+ messenger. onReceive { message in
31
31
self . onMessage ( message, self )
32
32
33
33
// Detect and ignore error responses.
Original file line number Diff line number Diff line change @@ -12,7 +12,7 @@ public protocol Messenger: AnyObject {
12
12
func send< S> ( _ message: S ) -> Void where S: Collection , S. Element == Character
13
13
14
14
/// Set the callback that should be run when a message is recieved
15
- func onRecieve ( callback: @escaping ( String ) -> Void ) -> Void
15
+ func onReceive ( callback: @escaping ( String ) -> Void ) -> Void
16
16
17
17
/// Close the messenger
18
18
func close( ) -> Void
Original file line number Diff line number Diff line change @@ -41,7 +41,7 @@ public class Server<InitPayload: Equatable & Codable> {
41
41
self . onExecute = onExecute
42
42
self . onSubscribe = onSubscribe
43
43
44
- messenger. onRecieve { message in
44
+ messenger. onReceive { message in
45
45
guard let messenger = self . messenger else { return }
46
46
47
47
self . onMessage ( message)
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ import Foundation
9
9
/// or risk them being deinitialized early
10
10
class TestMessenger : Messenger {
11
11
weak var other : TestMessenger ?
12
- var onRecieve : ( String ) -> Void = { _ in }
12
+ var onReceive : ( String ) -> Void = { _ in }
13
13
let queue : DispatchQueue = . init( label: " Test messenger " )
14
14
15
15
init ( ) { }
@@ -21,12 +21,12 @@ class TestMessenger: Messenger {
21
21
22
22
// Run the other message asyncronously to avoid nesting issues
23
23
queue. async {
24
- other. onRecieve ( String ( message) )
24
+ other. onReceive ( String ( message) )
25
25
}
26
26
}
27
27
28
- func onRecieve ( callback: @escaping ( String ) -> Void ) {
29
- self . onRecieve = callback
28
+ func onReceive ( callback: @escaping ( String ) -> Void ) {
29
+ self . onReceive = callback
30
30
}
31
31
32
32
func error( _ message: String , code: Int ) {
You can’t perform that action at this time.
0 commit comments