Lines Matching defs:cursor
11 type cursor struct { struct
12 pos int64
13 subscribers []*notifier
14 m sync.RWMutex
15 doneChan chan struct{}
20 func (c *cursor) Subscribe() *notifier {
29 func (c *cursor) Unsubscribe(n *notifier) {
52 func (c *cursor) Done() <-chan struct{} { return c.doneChan }
54 func (c *cursor) IsDone() bool {
65 func (c *cursor) SetPosition(pos int64) {
84 func (c *cursor) Position() int64 {