add query observable

avdwerff · avdwerff · commit aae324374742 · 2024-02-27T14:05:24.000+01:00
diff --git a/Sources/BasedClient/Based+AsyncSequence.swift b/Sources/BasedClient/Based+AsyncSequence.swift
@@ -8,6 +8,10 @@ enum SubscriptionType {
 }
 
 extension Based {
+
+    public func subscribe<Element: Decodable>(query: Query) throws -> AsyncThrowingStream<Element, Error> {
+        return basedAsyncThrowingStream(type: .query(query), based: self)
+    }
     
     public func subscribe<Payload: Encodable, Element: Decodable>(name: String, payload: Payload) throws -> AsyncThrowingStream<Element, Error> {
         let encoder = NakedJsonEncoder()

Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,10 @@ enum SubscriptionType {`
`8`	`8`	`}`
`9`	`9`
`10`	`10`	`extension Based {`
	`11`	`+`
	`12`	`+ public func subscribe<Element: Decodable>(query: Query) throws -> AsyncThrowingStream<Element, Error> {`
	`13`	`+ return basedAsyncThrowingStream(type: .query(query), based: self)`
	`14`	`+ }`
`11`	`15`
`12`	`16`	`public func subscribe<Payload: Encodable, Element: Decodable>(name: String, payload: Payload) throws -> AsyncThrowingStream<Element, Error> {`
`13`	`17`	`let encoder = NakedJsonEncoder()`