Subscribe subscribes given subscriber to query. Returns a channel with cap=1 onto which events are published. An error is returned if it fails to subscribe. outCapacity can be used optionally to set capacity for the channel. Channel is never closed to prevent accidental reads. ctx cannot be used to
(ctx context.Context, subscriber, query string, outCapacity ...int)
| 124 | // ctx cannot be used to unsubscribe. To unsubscribe, use either Unsubscribe |
| 125 | // or UnsubscribeAll. |
| 126 | Subscribe(ctx context.Context, subscriber, query string, outCapacity ...int) (out <-chan ctypes.ResultEvent, err error) |
| 127 | // Unsubscribe unsubscribes given subscriber from query. |
| 128 | Unsubscribe(ctx context.Context, subscriber, query string) error |
| 129 | // UnsubscribeAll unsubscribes given subscriber from all the queries. |
no outgoing calls