Skip to content

Commit 7d34001

Browse files
committed
[UPDATE] add update persistent subscription
1 parent 054072f commit 7d34001

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

Sources/KurrentDB/KurrentDBClient.swift

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -305,6 +305,20 @@ extension KurrentDBClient {
305305
.create(startFrom: cursor, options: options)
306306
}
307307

308+
public func updatePersistentSubscription(to streamIdentifier: StreamIdentifier, groupName: String, startFrom cursor: RevisionCursor = .end, configure: (PersistentSubscriptions<PersistentSubscription.Specified>.Update.Options) -> PersistentSubscriptions<PersistentSubscription.Specified>.Update.Options = { $0 }) async throws {
309+
let options = configure(.init())
310+
try await streams(of: .specified(streamIdentifier))
311+
.persistentSubscriptions(group: groupName)
312+
.update(startFrom: cursor, options: options)
313+
}
314+
315+
public func updatePersistentSubscriptionToAllStream(groupName: String, startFrom cursor: PositionCursor = .start, configure: (PersistentSubscriptions<PersistentSubscription.AllStream>.Update.Options) -> PersistentSubscriptions<PersistentSubscription.AllStream>.Update.Options = { $0 }) async throws {
316+
let options = configure(.init())
317+
try await streams(of: .all)
318+
.persistentSubscriptions(group: groupName)
319+
.update(startFrom: cursor, options: options)
320+
}
321+
308322
public func subscribePersistentSubscription(to streamIdentifier: StreamIdentifier, groupName: String, configure: (PersistentSubscriptions<PersistentSubscription.Specified>.ReadOptions) -> PersistentSubscriptions<PersistentSubscription.Specified>.ReadOptions = { $0 }) async throws -> PersistentSubscriptions<PersistentSubscription.Specified>.Subscription {
309323
let options = configure(.init())
310324
let stream = streams(of: .specified(streamIdentifier))

0 commit comments

Comments
 (0)