We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 985755e commit faf5532Copy full SHA for faf5532
Sources/TCP/Streams/TCPSocketSource.swift
@@ -142,13 +142,9 @@ 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
- guard !isCancelled else {
+ if !isCancelled {
146
// source is cancelled, we will never receive signals again
147
cancelIsPending = true
148
- if downstreamIsReady {
149
- readData()
150
- }
151
- return
152
}
153
154
guard downstreamIsReady else {
0 commit comments