Use refs to distinguish RPC responses

Now one can do

    {ok, Ref} = mqtt_connection:subscribe(C, [{"foo", at_most_once}]),
    receive {Ref, Reply} -> Reply after 1000 -> timeout end.