Method GetAckState

pkg/streamclient/streamwriter.go:99–104

()

}

func (w *Writer) GetAckState() (maxAckedSeq int64, finAcked bool, canceled bool) {
	w.lock.Lock()
	defer w.lock.Unlock()

	return w.maxAckedSeq, w.finAcked, w.canceled
}

func (w *Writer) GetCanceledChan() <-chan struct{} {
	return w.canceledChan