We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fce31b5 commit f5beac1Copy full SHA for f5beac1
Sources/Nats/NatsConnection.swift
@@ -47,7 +47,21 @@ class ConnectionHandler: ChannelInboundHandler {
47
private var clientKey: URL?
48
49
typealias InboundIn = ByteBuffer
50
- internal var state: NatsState = .pending
+ private let stateLock = NSLock()
51
+ private var _state: NatsState = .pending
52
+ internal var state: NatsState {
53
+ get{
54
+ stateLock.lock()
55
+ defer { stateLock.unlock() }
56
+ return _state
57
+ }
58
+ set{
59
60
61
+ _state = newValue
62
63
64
+
65
private var subscriptions: [UInt64: Subscription]
66
private var subscriptionCounter = ManagedAtomic<UInt64>(0)
67
private var serverInfo: ServerInfo?
0 commit comments