server/net/parser/pomelo/client/context.go

package pomeloClient

import (
	"time"

	cmsg "github.com/mhaya/net/parser/pomelo/message"
)

type (
	RequestContext struct {
		*time.Ticker
		Chan chan *cmsg.Message
	}
)

func NewRequestContext(t time.Duration) RequestContext {
	return RequestContext{
		Ticker: time.NewTicker(t),
		Chan:   make(chan *cmsg.Message, 1),
	}
}

func (p *RequestContext) Close() {
	if p.Chan != nil {
		close(p.Chan)
	}

	p.Ticker.Stop()
}