Hi, I think beam would benefit if it were to adopt the reactive streams api.
This would mean that all sources (currently have on next) would add oncomplete and onerror The same for sinks. This would make it much easier to add statuses and to handle empty sets and errors in sets chaim
