|
7 | 7 |
|
8 | 8 | import Foundation
|
9 | 9 |
|
10 |
| -public enum RealtimeFilter { |
11 |
| - case eq(_ column: String, value: any RealtimeFilterValue) |
12 |
| - case neq(_ column: String, value: any RealtimeFilterValue) |
13 |
| - case gt(_ column: String, value: any RealtimeFilterValue) |
14 |
| - case gte(_ column: String, value: any RealtimeFilterValue) |
15 |
| - case lt(_ column: String, value: any RealtimeFilterValue) |
16 |
| - case lte(_ column: String, value: any RealtimeFilterValue) |
17 |
| - case `in`(_ column: String, values: [any RealtimeFilterValue]) |
18 |
| - |
19 |
| - var value: String { |
20 |
| - switch self { |
21 |
| - case let .eq(column, value): |
22 |
| - return "\(column)=eq.\(value.rawValue)" |
23 |
| - case let .neq(column, value): |
24 |
| - return "\(column)=neq.\(value.rawValue)" |
25 |
| - case let .gt(column, value): |
26 |
| - return "\(column)=gt.\(value.rawValue)" |
27 |
| - case let .gte(column, value): |
28 |
| - return "\(column)=gte.\(value.rawValue)" |
29 |
| - case let .lt(column, value): |
30 |
| - return "\(column)=lt.\(value.rawValue)" |
31 |
| - case let .lte(column, value): |
32 |
| - return "\(column)=lte.\(value.rawValue)" |
33 |
| - case let .in(column, values): |
34 |
| - return "\(column)=in.(\(values.map(\.rawValue)))" |
35 |
| - } |
36 |
| - } |
37 |
| -} |
38 |
| - |
39 | 10 | extension RealtimeChannelV2 {
|
40 | 11 | /// Listen for clients joining / leaving the channel using presences.
|
41 | 12 | public func presenceChange() -> AsyncStream<any PresenceAction> {
|
|
0 commit comments