We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent de1f8ee commit aed00c1Copy full SHA for aed00c1
Sources/Realtime/RealtimeClientV2.swift
@@ -74,7 +74,10 @@ public final class RealtimeClientV2: Sendable {
74
///
75
/// You can also use ``onHeartbeat(_:)`` for a closure based method.
76
public var heartbeat: AsyncStream<HeartbeatStatus> {
77
- heartbeatSubject.values.compactMap { value -> HeartbeatStatus? in value }.eraseToStream()
+ AsyncStream(
78
+ heartbeatSubject.values.compactMap { $0 }
79
+ as AsyncCompactMapSequence<AsyncStream<HeartbeatStatus?>, HeartbeatStatus>
80
+ )
81
}
82
83
/// Listen for connection status changes.
0 commit comments