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