Introduction

dependencies: [
    .package(url: "https://github.com/gokulnair2001/Pledge.git", from: "1.0.0")
]

// Create an observable string
let messageObservable = PLObservable("Hello")

// Subscribe to changes
let subscription = messageObservable.subscribe { newMessage in
    print("Message changed to: \(newMessage)")
}

// Update the value
messageObservable.setValue("Hello World")

// Access shared instance
let store = PLGlobalStore.shared
// Get or create an observable
let userNameObservable = store.string(for: "userName", defaultValue: "Guest")
// Subscribe to changes
userNameObservable.subscribe { name in
    print("User name is now: \(name)")
}
// Update from anywhere in your app
PLGlobalStore.shared.string(for: "userName").setValue("John")

// Initialize with a value
let counter = PLObservable(0)
let isEnabled = PLObservable(true)
let userData = PLObservable(["name": "Guest", "role": "User"])

// Basic subscription
let subscription = observable.subscribe { newValue in
    print("Value changed to: \(newValue)")
}
// Unsubscribe when no longer needed
observable.unsubscribe(subscription)
// Remove all subscribers
observable.removeAllSubscribers()

// Deliver on a specific queue
observable.deliver(on: myCustomQueue).subscribe { value in
    // This closure runs on myCustomQueue
}
// Deliver on the main queue
observable.deliverOnMain().subscribe { value in
    // This closure runs on the main queue
}
// Set subscription priority
observable.withPriority(.high).subscribe { value in
    // High priority subscribers are notified first
}

// Set a new value and notify subscribers
observable.setValue(newValue)
// Set a value without notification
observable.setValue(newValue, notify: false)
// Trigger notification with current value
observable.notifyObservers()

// Begin batch updates
observable.beginUpdates()
// Make multiple changes
observable.setValue(1)
observable.setValue(2)
observable.setValue(3)
// End batch updates - only sends one notification
observable.endUpdates()

// Throttle: limit to one notification per 0.5 seconds
observable.throttle(for: 0.5).subscribe { value in
    // Called at most once per 0.5 seconds
}
// Debounce: wait until updates pause for 0.3 seconds
observable.debounce(for: 0.3).subscribe { value in
    // Called after 0.3 seconds of no updates
}

// Map values to a different type
let stringCounter = counter.map { "Count: \($0)" }
// Flat-map to another observable
let userDetails = userIdObservable.flatMap { userId in
    return fetchUserDetails(userId)
}
// Unwrap optional values
let optionalValue = PLObservable<String?>("test")
let unwrapped = optionalValue.compactMap()

// Only emit values that pass a predicate
let evenNumbers = counter.filter { $0 % 2 == 0 }
// Skip the first N emissions
let skipFirst = counter.skip(2)
// Only emit when value changes
let distinct = values.distinctUntilChanged()

// Merge two observables of the same type
let allEvents = userEvents.merge(systemEvents)
// Combine latest values from two observables
let credentials = username.zip(password)

// Get/create typed observables
let counter = PLGlobalStore.shared.integer(for: "counter")
let userName = PLGlobalStore.shared.string(for: "userName")
let settings = PLGlobalStore.shared.dictionary(for: "settings")
let items = PLGlobalStore.shared.array(for: "items")
let isEnabled = PLGlobalStore.shared.boolean(for: "isEnabled")
// Remove specific observable
PLGlobalStore.shared.removeObservable(for: "counter")
// Clear all observables
PLGlobalStore.shared.removeAllObservables()

let username = PLObservable("")
let password = PLObservable("")
let isFormValid = PLObservable(false)
// Create derived state
let isUsernameValid = username.map { $0.count >= 3 }
let isPasswordValid = password.map { $0.count >= 8 }
// Combine validations
isUsernameValid.subscribe { usernameValid in
    isPasswordValid.subscribe { passwordValid in
        isFormValid.setValue(usernameValid && passwordValid)
    }
}
// React to form validity
isFormValid.subscribe { valid in
    submitButton.isEnabled = valid
}

enum NetworkState {
    case idle, loading, success(Data), error(Error)
}
let networkState = PLObservable<NetworkState>(.idle)
// Handle different states
networkState.subscribe { state in
    switch state {
    case .idle:
        // Hide indicators
    case .loading:
        // Show loading spinner
    case .success(let data):
        // Update UI with data
    case .error(let error):
        // Show error message
    }
}
// Function to load data
func fetchData() {
    networkState.setValue(.loading)
    
    apiClient.fetchData { result in
        switch result {
        case .success(let data):
            networkState.setValue(.success(data))
        case .failure(let error):
            networkState.setValue(.error(error))
        }
    }
}

let searchQuery = PLObservable("")
// Throttle to avoid excessive API calls
searchQuery.throttle(for: 0.3).subscribe { query in
    if !query.isEmpty {
        performSearch(query)
    }
}