 	}
 	
 	func send(event: Event<T>) {
-		withLock(self.condition) { () -> () in
-			self.events.append(event)
-			self.condition.broadcast()
+		withLock(_condition) { () -> () in
+			self._events.append(event)
+			self._condition.broadcast()
 		}
 	}
 }

			}
		
			return Promise {
				let e: Event<T> = withLock(self.condition) {
					while self.events.count < index {
						self.condition.wait()
					}
					
					return self.events[index++]
				}
				
				if e.isTerminating {

import Foundation

@final class AsyncBuffer<T>: AsyncSequence<T> {
	let _condition = NSCondition()
	var _events: Event<T>[] = []
	
	init() {
		_condition.name = "com.github.RxSwift.Observable.AsyncBuffer"
		super.init(_generate)
	}

