Implement Queue#subscribe: using closures as consumers is now easy