projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix: GREEN - `ChatRoomData` obeys to the added expectations.
[demos/kafka/chat]
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
chat
/
backend
/
domain
/
ChatRoomData.java
diff --git
a/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
b/src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
index
d783eb4
..
9dbeda9
100644
(file)
--- a/
src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
+++ b/
src/main/java/de/juplo/kafka/chat/backend/domain/ChatRoomData.java
@@
-21,21
+21,21
@@
public class ChatRoomData
private final ChatMessageService service;
private final Clock clock;
private final ChatMessageService service;
private final Clock clock;
- private final int
bufferSize
;
+ private final int
historyLimit
;
private Sinks.Many<Message> sink;
public ChatRoomData(
Clock clock,
ChatMessageService service,
private Sinks.Many<Message> sink;
public ChatRoomData(
Clock clock,
ChatMessageService service,
- int
bufferSize
)
+ int
historyLimit
)
{
{
- log.info("Created ChatRoom with
buffer-size {}", bufferSize
);
+ log.info("Created ChatRoom with
history-limit {}", historyLimit
);
this.clock = clock;
this.service = service;
this.clock = clock;
this.service = service;
- this.
bufferSize = bufferSize
;
+ this.
historyLimit = historyLimit
;
// @RequiredArgsConstructor unfortunately not possible, because
// @RequiredArgsConstructor unfortunately not possible, because
- // the `
bufferSize
` is not set, if `createSink()` is called
+ // the `
historyLimit
` is not set, if `createSink()` is called
// from the variable declaration!
this.sink = createSink();
}
// from the variable declaration!
this.sink = createSink();
}
@@
-110,7
+110,7
@@
public class ChatRoomData
{
return Sinks
.many()
{
return Sinks
.many()
- .
multicast
()
- .
onBackpressureBuffer(bufferSize
);
+ .
replay
()
+ .
limit(historyLimit
);
}
}
}
}