michael/swift-tca-extras
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Made public

Browse Source
This commit is contained in:
Oliver Foggin
2023-12-14 17:57:40 +00:00
parent c4db397ce4
commit 6b42ceda4b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Sources/ComposableSubscriber/SubscriberReducer.swift
View File

@@ -1,7 +1,7 @@
import ComposableArchitecture import ComposableArchitecture
extension Reducer { extension Reducer {
func subscribe<TriggerAction, T>( public func subscribe<TriggerAction, T>(
on triggerAction: CaseKeyPath<Action, TriggerAction>, on triggerAction: CaseKeyPath<Action, TriggerAction>,
to stream: @escaping () async throws -> AsyncStream<T>, to stream: @escaping () async throws -> AsyncStream<T>,
with responseAction: CaseKeyPath<Action, T> with responseAction: CaseKeyPath<Action, T>
@@ -15,7 +15,7 @@ extension Reducer {
} }
} }
struct _SubscribeReducer<Parent: Reducer, TriggerAction, T>: Reducer { public struct _SubscribeReducer<Parent: Reducer, TriggerAction, T>: Reducer {
@usableFromInline @usableFromInline
let parent: Parent let parent: Parent
@@ -40,7 +40,7 @@ struct _SubscribeReducer<Parent: Reducer, TriggerAction, T>: Reducer {
self.responseAction = AnyCasePath(responseAction) self.responseAction = AnyCasePath(responseAction)
} }
func reduce(into state: inout Parent.State, action: Parent.Action) -> Effect<Parent.Action> { public func reduce(into state: inout Parent.State, action: Parent.Action) -> Effect<Parent.Action> {
let effects = parent.reduce(into: &state, action: action) let effects = parent.reduce(into: &state, action: action)
guard self.triggerAction.extract(from: action) != nil else { guard self.triggerAction.extract(from: action) != nil else {