func (a *Client) Subscribe(params *SubscribeParams) (*SubscribeOK, error) {
	if params == nil {
		params = NewSubscribeParams()
	}
	result, err := a.transport.Submit(&runtime.ClientOperation{
		ID:                 "Subscribe",
		Method:             "POST",
		PathPattern:        "/activity/subscribe",
		ProducesMediaTypes: []string{"application/json"},
		ConsumesMediaTypes: []string{"application/json"},
		Schemes:            []string{"http", "https", "wss"},
		Params:             params,
		Reader:             &SubscribeReader{formats: a.formats},
		Context:            params.Context,
		Client:             params.HTTPClient,
	})
	if err != nil {
		return nil, err
	}
	return result.(*SubscribeOK), nil
}
/*
Subscribe manages subscriptions to other users nodes feeds
package activity_service
import (
	"github.com/go-openapi/runtime"
	strfmt "github.com/go-openapi/strfmt"
)
func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client {
	return &Client{transport: transport, formats: formats}
}
type Client struct {
	transport runtime.ClientTransport
	formats   strfmt.Registry
}
func (a *Client) SearchSubscriptions(params *SearchSubscriptionsParams) (*SearchSubscriptionsOK, error) {
	if params == nil {
		params = NewSearchSubscriptionsParams()
	}
	result, err := a.transport.Submit(&runtime.ClientOperation{
		ID:                 "SearchSubscriptions",
		Method:             "POST",
		PathPattern:        "/activity/subscriptions",
		ProducesMediaTypes: []string{"application/json"},
		ConsumesMediaTypes: []string{"application/json"},
		Schemes:            []string{"http", "https", "wss"},
		Params:             params,
		Reader:             &SearchSubscriptionsReader{formats: a.formats},
		Context:            params.Context,
		Client:             params.HTTPClient,
	})
	if err != nil {
		return nil, err
	}
	return result.(*SearchSubscriptionsOK), nil
}
func (a *Client) Stream(params *StreamParams) (*StreamOK, error) {
	if params == nil {
		params = NewStreamParams()
	}
	result, err := a.transport.Submit(&runtime.ClientOperation{
		ID:                 "Stream",
		Method:             "POST",
		PathPattern:        "/activity/stream",
		ProducesMediaTypes: []string{"application/json"},
		ConsumesMediaTypes: []string{"application/json"},
		Schemes:            []string{"http", "https", "wss"},
		Params:             params,
		Reader:             &StreamReader{formats: a.formats},
		Context:            params.Context,
		Client:             params.HTTPClient,
	})
	if err != nil {
		return nil, err
	}
	return result.(*StreamOK), nil
}