<commit_before>import Foundation

public struct Observable<T> {

    // MARK: - Types

    public typealias SubscriptionType = Subscription<T>


    // MARK: - Properties

    private let eventQueue = dispatch_get_global_queue(QOS_CLASS_UTILITY, 0)

    public var value: T {
        didSet {
            dispatch_sync(eventQueue) {
                self.subscribers.send(self.value)
                self.onceSubscribers.send(self.value)
            }
        }
    }


    // MARK: - Initialization

    public init(_ value: T) {
        self.value = value
    }


    // MARK: - Subscribers

    private var subscribers = Subscriptions<T>()
    private var onceSubscribers = OnceSubscriptions<T>()

    public mutating func subscribe(handler: SubscriptionType.EventHandler) -> SubscriptionType {
        let subscription = Subscription(handler: handler)
        subscription.handler(value)
        subscribers.add(subscription)
        return subscription
    }

    public mutating func subscribeOnce(handler: SubscriptionType.EventHandler) {<commit_msg>Add named argument to initializer<commit_after>import Foundation

public struct Observable<T> {

    // MARK: - Types

    public typealias SubscriptionType = Subscription<T>


    // MARK: - Properties

    private let eventQueue = dispatch_get_global_queue(QOS_CLASS_UTILITY, 0)

    public var value: T {
        didSet {
            dispatch_sync(eventQueue) {
                self.subscribers.send(self.value)
                self.onceSubscribers.send(self.value)
            }
        }
    }


    // MARK: - Initialization

    public init(initial value: T) {
        self.value = value
    }


    // MARK: - Subscribers

    private var subscribers = Subscriptions<T>()
    private var onceSubscribers = OnceSubscriptions<T>()

    public mutating func subscribe(handler: SubscriptionType.EventHandler) -> SubscriptionType {
        let subscription = Subscription(handler: handler)
        subscription.handler(value)
        subscribers.add(subscription)
        return subscription
    }

    public mutating func subscribeOnce(handler: SubscriptionType.EventHandler) {
{'fraction_non_alphanumeric': 0.0823199251637044, 'fraction_numerical': 0.0009354536950420954, 'mean_word_length': 2.5355371900826444, 'pattern_counts': {'":': 0, '<': 11, '<?xml version=': 0, '>': 13, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3674483', 'n_tokens_mistral': 601, 'n_tokens_neox': 558, 'n_words': 130}