[HEAD MERGE] add consumer wake up pipe

Send wake up when stream still has data.

Signed-off-by: David Goulet <dgoulet@efficios.com>