Function amqpr::subscribe::subscribe_stream

pub fn subscribe_stream(
    exchange_name: String, 
    addr: SocketAddr, 
    user: String, 
    pass: String, 
    handle: Handle
) -> Box<Stream<Item = Bytes, Error = ()>>