I have the requirement of make sure that downstream processes all data currently being sent.
I usually have the client submit a Request struct the includes a new Done channel. When the downstream goroutine finishes processing a given Request r, they close the r.Done channel. The client can wait or select on the r.Done channel to know when processing is finished. -- You received this message because you are subscribed to the Google Groups "golang-nuts" group. To unsubscribe from this group and stop receiving emails from it, send an email to golang-nuts+unsubscr...@googlegroups.com. To view this discussion on the web visit https://groups.google.com/d/msgid/golang-nuts/201a1bc5-6f99-4ec5-a19a-40943e7d7c76n%40googlegroups.com.
