ABridoux

// Free to use
// Written by Alexis Bridoux - https://github.com/ABridoux

import AppKit

#if canImport(SwiftUI)
import SwiftUI
#endif

// MARK: Model

ABridoux

// Free to use
// Written by Alexis Bridoux - https://github.com/ABridoux

/// Observes a notification and executes the provided block upon reception
///
/// Unregister the stored observer upon deinitialization
final class NotificationObserver {

    var name: Notification.Name
    var observer: NSObjectProtocol

ABridoux

// Free to use
// Written by Alexis Bridoux - https://github.com/ABridoux

import AppKit
import Foundation

/// Service to shut down, restart, or put the computer to sleep. Also log out the user.
///
/// ### Resources
/// - [Apple doc](https://developer.apple.com/library/archive/qa/qa1134/_index.html)

ABridoux

struct ReducedReplayAsyncStream<Element> {

    typealias Reduce = (_ partialResult: inout Element, _ nextResult: Element) -> Void

    private let storage: _Storage
    private var originalStream: AsyncStream<Element>

    init(
        bufferingPolicy limit: AsyncStream<Element>.Continuation.BufferingPolicy = .unbounded,
        initialResult: Element,

ABridoux

import AVFoundation

// MARK: - MatrixMixerNodeWrapper

/// Wrapper around an audio unit node of type `kAudioUnitSubType_MatrixMixer` for convenience.
public final class MatrixMixerNodeWrapper {

    // MARK: Properties

    /// Matrix mixer to map input channels

ABridoux

// MARK: - Queue

struct Queue<Element> {
    private var enqueueArray: [Element] = []
    private var dequeueArray: [Element] = []

    var isEmpty: Bool {
        enqueueArray.isEmpty && dequeueArray.isEmpty
    }
}

ABridoux

// MARK: - Check error

extension OSStatus {

    /// Error mapped from an `OSStatus`.
    public struct StatusError: Error {

        // MARK: Properties

        let status: OSStatus