queue

Jan 26, 2023

Changes in this version

+ func TypedValueOf(v *fpb.Value) *gpb.TypedValue

+ func ValueOf(v *fpb.Value) interface

+ type FixedQueue struct

+ func NewFixed(resp []*gpb.SubscribeResponse, delay bool) *FixedQueue

+ func (q *FixedQueue) Add(resp *gpb.SubscribeResponse)

+ func (q *FixedQueue) Next() (interface{}, error)

+ type Queue interface

+ Next func() (interface{}, error)

+ type UpdateQueue struct

+ func New(delay bool, seed int64, values []*fpb.Value) *UpdateQueue

+ func (u *UpdateQueue) Add(v *fpb.Value)

+ func (u *UpdateQueue) Latest() int64

+ func (u *UpdateQueue) Next() (interface{}, error)