diff --git a/Sources/ComposableSubscriber/SubscriberReducer.swift b/Sources/ComposableSubscriber/SubscriberReducer.swift index c451d5b..2f08693 100644 --- a/Sources/ComposableSubscriber/SubscriberReducer.swift +++ b/Sources/ComposableSubscriber/SubscriberReducer.swift @@ -134,14 +134,14 @@ extension Reducer { /// ``` /// /// - Parameters: - /// - toStreamArgument: The argument used to invoke the stream with. /// - stream: The async stream to subscribe to on the reducer + /// - toStreamArgument: The argument used to invoke the stream with. /// - triggerAction: The action to invoke the stream when received. /// - responseAction: The action to invoke with the streamed elements. /// - animation: Optional animation used when elements are received. public func subscribe( - using toStreamArgument: @escaping @Sendable (State) -> StreamArgument, to stream: @escaping @Sendable (StreamArgument) async -> AsyncStream, + using toStreamArgument: @escaping @Sendable (State) -> StreamArgument, on triggerAction: CaseKeyPath, with responseAction: CaseKeyPath, animation: Animation? = nil @@ -294,14 +294,14 @@ extension Reducer { /// ``` /// /// - Parameters: - /// - toStreamArgument: The argument used to invoke the stream with. /// - stream: The async stream to subscribe to on the reducer + /// - toStreamArgument: The argument used to invoke the stream with. /// - triggerAction: The action to invoke the stream when received. /// - responseAction: The action to invoke with the streamed elements. /// - animation: Optional animation used when elements are received. public func subscribe( - using toStreamArgument: @escaping @Sendable (State) -> StreamArgument, to stream: @escaping @Sendable (StreamArgument) async -> AsyncStream, + using toStreamArgument: @escaping @Sendable (State) -> StreamArgument, on triggerAction: CaseKeyPath, with responseAction: CaseKeyPath, animation: Animation? = nil, @@ -455,14 +455,14 @@ extension Reducer { /// ``` /// /// - Parameters: - /// - toStreamArgument: The argument used to invoke the stream with. /// - stream: The async stream to subscribe to on the reducer + /// - toStreamArgument: The argument used to invoke the stream with. /// - triggerAction: The action to invoke the stream when received. /// - responseAction: The action to invoke with the streamed elements. /// - animation: Optional animation used when elements are received. public func subscribe( - using toStreamArgument: @escaping @Sendable (State) -> StreamArgument, to stream: @escaping @Sendable (StreamArgument) async -> AsyncStream, + using toStreamArgument: @escaping @Sendable (State) -> StreamArgument, on triggerAction: CaseKeyPath, operation: @escaping @Sendable (_ send: Send, StreamElement) async throws -> Void ) -> _SubscribeReducer {