File tree Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -2,23 +2,24 @@ import Foundation
2
2
@_spi ( Internal) import _Helpers
3
3
4
4
struct EventEmitter : Sendable {
5
- var attachListener : @Sendable ( ) async -> (
5
+ var attachListener : @Sendable ( ) -> (
6
6
id: UUID ,
7
7
stream: AsyncStream < ( event: AuthChangeEvent , session: Session ? ) >
8
8
)
9
- var emit : @Sendable ( _ event: AuthChangeEvent , _ session: Session ? , _ id: UUID ? ) async -> Void
9
+ var emit : @Sendable ( _ event: AuthChangeEvent , _ session: Session ? , _ id: UUID ? ) -> Void
10
10
}
11
11
12
12
extension EventEmitter {
13
- func emit( _ event: AuthChangeEvent , session: Session ? ) async {
14
- await emit ( event, session, nil )
13
+ func emit( _ event: AuthChangeEvent , session: Session ? ) {
14
+ emit ( event, session, nil )
15
15
}
16
16
}
17
17
18
18
extension EventEmitter {
19
19
static var live : Self = {
20
- let continuations =
21
- ActorIsolated ( [ UUID: AsyncStream< ( event: AuthChangeEvent, session: Session? ) > . Continuation] ( ) )
20
+ let continuations = LockIsolated (
21
+ [ UUID: AsyncStream< ( event: AuthChangeEvent, session: Session? ) > . Continuation] ( )
22
+ )
22
23
23
24
return Self (
24
25
attachListener: {
You can’t perform that action at this time.
0 commit comments