diff --git a/client.go b/client.go index f89e9f7..793a2a7 100644 --- a/client.go +++ b/client.go @@ -304,6 +304,8 @@ func (c *Client) Paginate(fql *Query, opts ...QueryOptFn) *QueryIterator { // // Note that the query provided MUST return [fauna.Stream] value. Otherwise, // this method returns an error. +// +// Deprecated: will be replaced in future versions func (c *Client) Stream(fql *Query, opts ...QueryOptFn) (*Events, error) { res, err := c.Query(fql, opts...) if err != nil { @@ -318,6 +320,8 @@ func (c *Client) Stream(fql *Query, opts ...QueryOptFn) (*Events, error) { } // Subscribe initiates a stream subscription for the given stream value. +// +// Deprecated: will be replaced in future versions func (c *Client) Subscribe(stream Stream, opts ...StreamOptFn) (*Events, error) { return subscribe(c, stream, opts...) } diff --git a/stream.go b/stream.go index 2545289..ef3c90b 100644 --- a/stream.go +++ b/stream.go @@ -86,6 +86,8 @@ func (e *ErrEvent) Unmarshal(into any) error { // not read to completion and closed. By default, Fauna's region groups use the // HTTP/2.x protocol where this restriction don't apply. However, if connecting // to Fauna via an HTTP/1.x proxy, be aware of the events iterator closing time. +// +// Deprecated: will be replaced in future versions type Events struct { client *Client stream Stream