Versions in this module Expand all Collapse all v0 v0.0.1 Apr 28, 2022 Changes in this version + var ErrInvalidChannel = errors.New("invalid channel") + type ChanStream struct + func NewChanStream(t <-chan ticker.Price, errs <-chan error) (*ChanStream, error) + func (s *ChanStream) Get(ctx context.Context) (*ticker.Price, error) + type Stream interface + Get func(ctx context.Context) (*ticker.Price, error)
Go to main page