Skip to content

Commit 9fd0f26

Browse files
committed
Delete trailing whitespace in AsyncStreamBuffer.swift
Verifying that the ANSI color control sequences don't show up in CI logs. AsyncStreamBuffer.swift emits warnings, so dirtying it will ensure it gets rebuilt in CI.
1 parent 2785d18 commit 9fd0f26

File tree

1 file changed

+15
-15
lines changed

1 file changed

+15
-15
lines changed

stdlib/public/Concurrency/AsyncStreamBuffer.swift

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ extension AsyncStream {
112112
let handler = state.onTermination
113113
state.onTermination = nil
114114
unlock()
115-
115+
116116
// handler must be invoked before yielding nil for termination
117117
handler?(.cancelled)
118118

@@ -124,7 +124,7 @@ extension AsyncStream {
124124
lock()
125125
let limit = state.limit
126126
let count = state.pending.count
127-
127+
128128
if !state.continuations.isEmpty {
129129
let continuation = state.continuations.removeFirst()
130130
if count > 0 {
@@ -170,7 +170,7 @@ extension AsyncStream {
170170
case .bufferingOldest(let limit):
171171
result = .enqueued(remaining: limit)
172172
}
173-
173+
174174
unlock()
175175
continuation.resume(returning: value)
176176
}
@@ -205,7 +205,7 @@ extension AsyncStream {
205205
}
206206
return result
207207
}
208-
208+
209209
func finish() {
210210
lock()
211211
let handler = state.onTermination
@@ -249,9 +249,9 @@ extension AsyncStream {
249249
} else {
250250
unlock()
251251
}
252-
252+
253253
}
254-
254+
255255
func next() async -> Element? {
256256
await withTaskCancellationHandler { [cancel] in
257257
cancel()
@@ -289,7 +289,7 @@ extension AsyncThrowingStream {
289289
case finished
290290
case failed(Failure)
291291
}
292-
292+
293293
struct State {
294294
var continuation: UnsafeContinuation<Element?, Error>?
295295
var pending = _Deque<Element>()
@@ -345,7 +345,7 @@ extension AsyncThrowingStream {
345345
let handler = state.onTermination
346346
state.onTermination = nil
347347
unlock()
348-
348+
349349
// handler must be invoked before yielding nil for termination
350350
handler?(.cancelled)
351351

@@ -409,7 +409,7 @@ extension AsyncThrowingStream {
409409
case .bufferingNewest(let limit):
410410
result = .enqueued(remaining: limit)
411411
}
412-
412+
413413
state.continuation = nil
414414
unlock()
415415
continuation.resume(returning: value)
@@ -445,7 +445,7 @@ extension AsyncThrowingStream {
445445
}
446446
return result
447447
}
448-
448+
449449
func finish(throwing error: __owned Failure? = nil) {
450450
lock()
451451
let handler = state.onTermination
@@ -510,7 +510,7 @@ extension AsyncThrowingStream {
510510
fatalError("attempt to await next() on more than one task")
511511
}
512512
}
513-
513+
514514
func next() async throws -> Element? {
515515
try await withTaskCancellationHandler { [cancel] in
516516
cancel()
@@ -546,7 +546,7 @@ final class _AsyncStreamCriticalStorage<Contents>: @unchecked Sendable {
546546
private init(_doNotCallMe: ()) {
547547
fatalError("_AsyncStreamCriticalStorage must be initialized by create")
548548
}
549-
549+
550550
private func lock() {
551551
let ptr =
552552
UnsafeRawPointer(Builtin.projectTailElems(self, UnsafeRawPointer.self))
@@ -558,15 +558,15 @@ final class _AsyncStreamCriticalStorage<Contents>: @unchecked Sendable {
558558
UnsafeRawPointer(Builtin.projectTailElems(self, UnsafeRawPointer.self))
559559
_unlock(ptr)
560560
}
561-
561+
562562
var value: Contents {
563563
get {
564564
lock()
565565
let contents = _value
566566
unlock()
567567
return contents
568568
}
569-
569+
570570
set {
571571
lock()
572572
withExtendedLifetime(_value) {
@@ -575,7 +575,7 @@ final class _AsyncStreamCriticalStorage<Contents>: @unchecked Sendable {
575575
}
576576
}
577577
}
578-
578+
579579
static func create(_ initial: Contents) -> _AsyncStreamCriticalStorage {
580580
let minimumCapacity = _lockWordCount()
581581
let storage = Builtin.allocWithTailElems_1(

0 commit comments

Comments
 (0)