waitingq

type WaitingReplyQueue ¶

type WaitingReplyQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

waitingReplyQueue abstracts a queue where requests on multiple goroutines must be made one at a time to a backing service because replies must be received in order.

A new initialized value is ready for use and must not be copied. Note that passing different contexts to the different functions may result in memory leaks.

func (wq *WaitingReplyQueue) ReplyLastSend(ctx context.Context, v interface{}) error

func (wq *WaitingReplyQueue) WaitForReadyToSend(ctx context.Context) chan interface{}