 		}
 	}
 
+	/// Returns a stream that will yield the first `count` values from the
+	/// receiver, where `count` is greater than zero.
 	@final func take(count: Int) -> Observable<T> {
 		assert(count > 0)
 

		}
	}

	@final func skipRepeats<U: Equatable>(evidence: Observable<T> -> Observable<U>) -> Observable<U> {
		return Observable<U> { send in
			let maybePrevious = Atomic<U?>(nil)

		}
	}

	/// Buffers values yielded by the receiver, preserving them for future
	/// enumeration.
	///
	/// capacity - If not nil, the maximum number of values to buffer. If more
	///            are received, the earliest values are dropped and won't be
	///            enumerated over in the future.
	///
	/// Returns an Enumerable over the buffered values, and a Disposable which
	/// can be used to cancel all further buffering.
	@final func buffer(capacity: Int? = nil) -> (Enumerable<T>, Disposable) {
		let enumerable = EnumerableBuffer<T>(capacity: capacity)

