@@ -46,9 +46,6 @@ public final class JSONRPCConnection: Connection {
46
46
private let sendIO : DispatchIO
47
47
private let messageRegistry : MessageRegistry
48
48
49
- /// *For Testing* Whether to wait for requests to finish before handling the next message.
50
- private let syncRequests : Bool
51
-
52
49
enum State {
53
50
case created, running, closed
54
51
}
@@ -108,8 +105,7 @@ public final class JSONRPCConnection: Connection {
108
105
name: String ,
109
106
protocol messageRegistry: MessageRegistry ,
110
107
inFD: FileHandle ,
111
- outFD: FileHandle ,
112
- syncRequests: Bool = false
108
+ outFD: FileHandle
113
109
) {
114
110
self . name = name
115
111
self . receiveHandler = nil
@@ -122,7 +118,6 @@ public final class JSONRPCConnection: Connection {
122
118
#endif
123
119
state = . created
124
120
self . messageRegistry = messageRegistry
125
- self . syncRequests = syncRequests
126
121
127
122
let ioGroup = DispatchGroup ( )
128
123
@@ -330,12 +325,9 @@ public final class JSONRPCConnection: Connection {
330
325
case . notification( let notification) :
331
326
notification. _handle ( self . receiveHandler!)
332
327
case . request( let request, id: let id) :
333
- let semaphore : DispatchSemaphore ? = syncRequests ? . init( value: 0 ) : nil
334
328
request. _handle ( self . receiveHandler!, id: id) { ( response, id) in
335
329
self . sendReply ( response, id: id)
336
- semaphore? . signal ( )
337
330
}
338
- semaphore? . wait ( )
339
331
case . response( let response, id: let id) :
340
332
guard let outstanding = outstandingRequests. removeValue ( forKey: id) else {
341
333
logger. error ( " No outstanding requests for response ID \( id, privacy: . public) " )
0 commit comments