void subscriptionChanged(RespSubscribeController controller) { changed.add(controller); prepareSending(); }