Method GetTickerStream

engine/rpcserver.go:2176–2245

GetTickerStream streams the requested updated ticker

(r *gctrpc.GetTickerStreamRequest, stream gctrpc.GoCryptoTraderService_GetTickerStreamServer)

// GetTickerStream streams the requested updated ticker
func (s *RPCServer) GetTickerStream(r *gctrpc.GetTickerStreamRequest, stream gctrpc.GoCryptoTraderService_GetTickerStreamServer) error {
	if r.Exchange == "" {
		return common.ErrExchangeNameNotSet
	}

	if _, err := s.GetExchangeByName(r.Exchange); err != nil {
		return err
	}

	a, err := asset.New(r.AssetType)
	if err != nil {
		return err
	}

	if r.Pair.String() == "" {
		return errCurrencyPairUnset
	}

	if r.AssetType == "" {
		return errAssetTypeUnset
	}

	p, err := currency.NewPairFromStrings(r.Pair.Base, r.Pair.Quote)
	if err != nil {
		return err
	}

	pipe, err := ticker.SubscribeTicker(r.Exchange, p, a)
	if err != nil {
		return err
	}

	defer func() {
		pipeErr := pipe.Release()
		if pipeErr != nil {
			log.Errorln(log.DispatchMgr, pipeErr)
		}
	}()

	for {
		data, ok := <-pipe.Channel()
		if !ok {
			return errDispatchSystem
		}

		t, ok := data.(*ticker.Price)
		if !ok {
			return common.GetTypeAssertError("*ticker.Price", data)
		}

		err := stream.Send(&gctrpc.TickerResponse{
			Pair: &gctrpc.CurrencyPair{
				Base:      t.Pair.Base.String(),
				Quote:     t.Pair.Quote.String(),
				Delimiter: t.Pair.Delimiter,
			},
			LastUpdated: s.unixTimestamp(t.LastUpdated),
			Last:        t.Last,