Use non-blocking channel to correctly support subscriptions rates