stream

Documentation

Index

• Variables
• type ChanStream
  • func NewChanStream(t <-chan ticker.Price, errs <-chan error) (*ChanStream, error)
  • func (s *ChanStream) Get(ctx context.Context) (*ticker.Price, error)
• type Stream

Variables

var ErrInvalidChannel = errors.New("invalid channel")

Types

type ChanStream

type ChanStream struct {
	// contains filtered or unexported fields
}

ChanStream streams ticker price using channels.

func NewChanStream

func NewChanStream(t <-chan ticker.Price, errs <-chan error) (*ChanStream, error)

NewChanStream returns new ChanStream instance.

func (*ChanStream) Get

func (s *ChanStream) Get(ctx context.Context) (*ticker.Price, error)

Get returns incoming TickerPrice.

type Stream

type Stream interface {
	Get(ctx context.Context) (*ticker.Price, error)
}

Stream streams ticker price.