如何使用AnyPublisher包装AVPlayer播放、暂停方法适配ReCombine

常见实现报错的核心原因 #

• 第一处报错（Key path cannot refer to instance method 'play()'）：AVPlayer提供的publisher(for:)是基于KVO机制的属性监听能力，仅支持监听符合KVC/KVO规范的实例属性，无法通过key path指向实例方法，该写法从机制上就不成立。
• 第二处报错（类型不匹配）：AVPlayer.play 本质是(AVPlayer) -> () -> Void类型的方法引用，属于函数类型，完全不满足Publisher协议的类型要求，直接返回自然触发类型校验失败。

正确封装逻辑 #

ReCombine的Effect设计范式是：上游收到对应Action -> 执行副作用逻辑 -> 可选返回需要分发的新Action。控制类方法（play/pause）是需要主动触发的副作用，不需要被包装成Combine发布者，只需要在Effect的执行上下文中直接调用即可。

步骤1：实现收敛的播放管理实例 #

单独封装持有AVPlayer的管理类，避免零散的实例扩展带来的逻辑混乱：

import AVFoundation
import Combine

final class AudioPlaybackManager {
    static let shared = AudioPlaybackManager()
    /// 内部持有的AVPlayer核心实例
    let player: AVPlayer
    
    /// 对外暴露的播放状态监听发布者（可直接复用你最初写的KVO监听逻辑）
    lazy var timeControlStatusPublisher: AnyPublisher<AVPlayer.TimeControlStatus, Never> = {
        player.publisher(for: \.timeControlStatus)
            .eraseToAnyPublisher()
    }()
    
    private init() {
        // 按需配置音频会话、初始化播放器
        self.player = AVPlayer()
    }
    
    /// 执行播放动作的纯方法
    func playStream() {
        player.play()
    }
    
    /// 执行暂停动作的纯方法
    func pauseStream() {
        player.pause()
    }
}

步骤2：适配ReCombine的Effect实现 #

修正原有Effect的flatMap逻辑，在收到Action时直接调用播放控制方法：

// 定义ReCombine的基础Action、Reducer结构
enum PlaybackAction: Action {
    case togglePlayStatus
    case syncPlaybackStatus(AVPlayer.TimeControlStatus)
}

struct PlaybackState {
    var isPlaying: Bool = false
}

let playbackReducer = Reducer<PlaybackState, PlaybackAction> { state, action in
    switch action {
    case .togglePlayStatus:
        state.isPlaying.toggle()
    case .syncPlaybackStatus(let status):
        state.isPlaying = (status == .playing)
    }
}

// 实现对应Effect
enum PlaybackEffect {
    /// 处理播放/暂停切换的Effect
    static let togglePlayPause = Effect(dispatch: false) { (actions: AnyPublisher<PlaybackAction, Never>) in
        actions.ofTypes(PlaybackAction.togglePlayStatus)
            .flatMap { _ -> AnyPublisher<PlaybackAction, Never> in
                // 收到切换Action时，直接判断当前状态执行对应控制逻辑
                let currentStatus = AudioPlaybackManager.shared.player.timeControlStatus
                if currentStatus == .playing {
                    AudioPlaybackManager.shared.pauseStream()
                } else {
                    AudioPlaybackManager.shared.playStream()
                }
                // 无后续Action需要分发时，直接返回空发布者即可
                return Empty().eraseToAnyPublisher()
            }
            .eraseToAnyPublisher()
    }
    
    /// 监听AVPlayer播放状态、同步到Store的Effect
    static let observePlaybackChange = Effect(dispatch: true) { (actions: AnyPublisher<PlaybackAction, Never>) in
        AudioPlaybackManager.shared.timeControlStatusPublisher
            .map { PlaybackAction.syncPlaybackStatus($0) }
            .eraseToAnyPublisher()
    }
}

设计注意要点 #

• 不需要强行将控制类方法包装为Combine发布者：Combine发布者的核心用途是广播值的持续变化，不是触发单次方法调用。
• 原实现中针对timeControlStatus的KVO监听逻辑是完全正确的，可以直接复用，用于同步播放器状态到全局Store。
• 播放控制逻辑作为副作用，在Effect收到Action的回调中直接调用，完全匹配ReCombine的单向数据流设计，不需要额外的发布者封装。

内容的提问来源于stack exchange，提问作者signal.space