func (c *Client) InitOffers() error {
	c.Offers = make(chan Offer, 100)
	err := c.startOffersConsumer()
	if err != nil {
		return err
	}
	return nil
}
Initializes offers public exchange.
package cwapi
import (
	"encoding/json"
	"fmt"
	"log"
)
func (c *Client) InitDeals() error {
	c.Deals = make(chan Deal, 100)
	err := c.startDealsConsumer()
	if err != nil {
		return err
	}
	return nil
}
func (c *Client) startDealsConsumer() error {
	updates, err := c.channelForUpdates.Consume(
		fmt.Sprintf("%s_deals", c.User),
		"",
		false,
		false,
		false,
		false,
		nil,
	)
	if err != nil {
		return err
	}
	go func() {
		for update := range updates {
			var res Deal
			err := json.Unmarshal(update.Body, &res)
			if err != nil {
				log.Println(err)
			}
			c.Deals <- res
			update.Ack(false)
		}
	}()
	return nil
}
func (c *Client) InitDuels() error {
	c.Duels = make(chan Duel, 100)
	err := c.startDuelsConsumer()
	if err != nil {
		return err
	}
	return nil
}
func (c *Client) startDuelsConsumer() error {
	updates, err := c.channelForUpdates.Consume(
		fmt.Sprintf("%s_duels", c.User),
		"",
		false,
		false,
		false,
		false,
		nil,
	)
	if err != nil {
		return err
	}
	go func() {
		for update := range updates {
			var res Duel
			err := json.Unmarshal(update.Body, &res)
			if err != nil {
				log.Println(err)
			}
			c.Duels <- res
			update.Ack(false)
		}
	}()
	return nil
}