Change streaming to use DeferredQueue

We should probably use a unique marker object here, because `False` might be a valid object somewhere. See https://github.com/praekelt/vumi/blob/develop/vumi/service.py#L287 for an example of how we use this elsewhere.