connections

type FeedUpdate struct {
	SubscriptionID string          `json:"subscription"`
	Result         json.RawMessage `json:"result"`
}

type HTTPError struct {
	Code    int         `json:"code"`
	Details interface{} `json:"details"`
	Message string      `json:"message"`
}

type Streamer[T any] func() (T, error)

type SubscribeParams struct {
	StreamName string
	StreamOpts json.RawMessage
}

type UnsubscribeParams struct {
	SubscriptionID string
}

type WS struct {

	// public to allow overriding of (un)subscribe method name
	SubscribeMethodName   string
	UnsubscribeMethodName string
	// contains filtered or unexported fields
}