+ private final Sinks.Many<Message> sink;
+
+ public Chatroom(
+ UUID id,
+ String name,
+ PersistenceStrategy persistence,
+ int bufferSize)
+ {
+ this.id = id;
+ this.name = name;
+ this.persistence = persistence;
+ this.sink = Sinks.many().multicast().onBackpressureBuffer(bufferSize);
+ }
+