We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1a79c9d commit b7386b4Copy full SHA for b7386b4
Sources/TCP/Streams/TCPSocketSource.swift
@@ -142,7 +142,7 @@ public final class TCPSocketSource: Async.OutputStream {
142
/// Called when the read source signals.
143
private func readSourceSignal(isCancelled: Bool) {
144
DEBUG("TCPSocketSource.readSourceSignal(\(isCancelled))")
145
- if !isCancelled {
+ if isCancelled {
146
// source is cancelled, we will never receive signals again
147
cancelIsPending = true
148
}
0 commit comments