How to publish messages from a room with reactive programming?What is (functional) reactive programming?The difference between Reactive and Functional-Reactive programmingWhat's the status of current Functional Reactive Programming implementations?How to implement Hot Stream in Reactive ProgrammingHow to modify results from a Flux with Spring ReactiveSending JMS messages in a Spring WebFlux reactive handler: is it blocking?Reactive programming how to implement dependent resultConvert a callback into a reactive publisher (Flux)Reactive programmingHow to broadcast messages in Spring Reactive Websocket API?
Why is Na5 not played in this line of the French Defense, Advance Variation?
Why am I getting a strange double quote (“) in Open Office instead of the ordinary one (")?
What does the pair of vertical lines in empirical entropy formula mean?
Can we completely replace inheritance using strategy pattern and dependency injection?
Is it possible to have 2 different but equal size real number sets that have the same mean and standard deviation?
Increase speed altering column on large table to NON NULL
How to befriend someone who doesn't like to talk?
empApi with Lightning Web Components?
Fermat's statement about the ancients: How serious was he?
Do you have to have figures when playing D&D?
Is it okay to have a sequel start immediately after the end of the first book?
Analogy between an unknown in an argument, and a contradiction in the principle of explosion
Why is long-term living in Almost-Earth causing severe health problems?
What differences exist between adamantine and adamantite in all editions of D&D?
Does the Nuka-Cola bottler actually generate nuka cola?
Has there been a multiethnic Star Trek character?
Is it possible to fly backward if you have really strong headwind?
The origin of the Russian proverb about two hares
Is Lambda Calculus purely syntactic?
Solving ‘Null geometry…’ error during distance matrix operation?
Electricity free spaceship
How can I remove material from this wood beam?
Live action TV show where High school Kids go into the virtual world and have to clear levels
What would prevent chimeras from reproducing with each other?
How to publish messages from a room with reactive programming?
What is (functional) reactive programming?The difference between Reactive and Functional-Reactive programmingWhat's the status of current Functional Reactive Programming implementations?How to implement Hot Stream in Reactive ProgrammingHow to modify results from a Flux with Spring ReactiveSending JMS messages in a Spring WebFlux reactive handler: is it blocking?Reactive programming how to implement dependent resultConvert a callback into a reactive publisher (Flux)Reactive programmingHow to broadcast messages in Spring Reactive Websocket API?
.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;
I deal with the topic of reactive programming.
I use WebFlux and R2dbc to access the database.
I am developing a small backend for a chat app.
So I have some questions on the subject and I would be very happy about suggestions and improvements.
This is service class
@Service
public class MessageService implements IMessageService
UnicastProcessor<Message> hotProcessor = UnicastProcessor.create();
private final FluxSink<Message> fluxSink = hotProcessor.sink(FluxSink.OverflowStrategy.LATEST);
private final Flux<Message> hotFlux = hotProcessor.publish().autoConnect();
@Autowired
private MessageRepository messageRepository;
public Flux<Message> findAll()
return this.messageRepository.findAll();
public Mono<Message> create(Message nachricht)
this.fluxSink.next(nachricht);
return this.messageRepository.save(nachricht);
// how can I persist messages and to arrange a chat room.
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getId().intValue() == id.intValue());
When should I use UnicastProcessor when DirectProcessor.
Update:
a little correction
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getRoom_id == id);
But how can I get all the Messages from the database and add it to fluxSink?
reactive-programming spring-webflux spring-data-r2dbc
add a comment |
I deal with the topic of reactive programming.
I use WebFlux and R2dbc to access the database.
I am developing a small backend for a chat app.
So I have some questions on the subject and I would be very happy about suggestions and improvements.
This is service class
@Service
public class MessageService implements IMessageService
UnicastProcessor<Message> hotProcessor = UnicastProcessor.create();
private final FluxSink<Message> fluxSink = hotProcessor.sink(FluxSink.OverflowStrategy.LATEST);
private final Flux<Message> hotFlux = hotProcessor.publish().autoConnect();
@Autowired
private MessageRepository messageRepository;
public Flux<Message> findAll()
return this.messageRepository.findAll();
public Mono<Message> create(Message nachricht)
this.fluxSink.next(nachricht);
return this.messageRepository.save(nachricht);
// how can I persist messages and to arrange a chat room.
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getId().intValue() == id.intValue());
When should I use UnicastProcessor when DirectProcessor.
Update:
a little correction
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getRoom_id == id);
But how can I get all the Messages from the database and add it to fluxSink?
reactive-programming spring-webflux spring-data-r2dbc
I see three different questions in the body and the title of your text. Please clarify which you want to be answered and what the exact problem is.
– Jens Schauder
Mar 26 at 6:31
Thank you for your reply. I want to save data in database and if anyone is in the chat room, then he should get messages. I'm very unsure what to do exactly.
– user9565938
Mar 26 at 10:31
add a comment |
I deal with the topic of reactive programming.
I use WebFlux and R2dbc to access the database.
I am developing a small backend for a chat app.
So I have some questions on the subject and I would be very happy about suggestions and improvements.
This is service class
@Service
public class MessageService implements IMessageService
UnicastProcessor<Message> hotProcessor = UnicastProcessor.create();
private final FluxSink<Message> fluxSink = hotProcessor.sink(FluxSink.OverflowStrategy.LATEST);
private final Flux<Message> hotFlux = hotProcessor.publish().autoConnect();
@Autowired
private MessageRepository messageRepository;
public Flux<Message> findAll()
return this.messageRepository.findAll();
public Mono<Message> create(Message nachricht)
this.fluxSink.next(nachricht);
return this.messageRepository.save(nachricht);
// how can I persist messages and to arrange a chat room.
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getId().intValue() == id.intValue());
When should I use UnicastProcessor when DirectProcessor.
Update:
a little correction
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getRoom_id == id);
But how can I get all the Messages from the database and add it to fluxSink?
reactive-programming spring-webflux spring-data-r2dbc
I deal with the topic of reactive programming.
I use WebFlux and R2dbc to access the database.
I am developing a small backend for a chat app.
So I have some questions on the subject and I would be very happy about suggestions and improvements.
This is service class
@Service
public class MessageService implements IMessageService
UnicastProcessor<Message> hotProcessor = UnicastProcessor.create();
private final FluxSink<Message> fluxSink = hotProcessor.sink(FluxSink.OverflowStrategy.LATEST);
private final Flux<Message> hotFlux = hotProcessor.publish().autoConnect();
@Autowired
private MessageRepository messageRepository;
public Flux<Message> findAll()
return this.messageRepository.findAll();
public Mono<Message> create(Message nachricht)
this.fluxSink.next(nachricht);
return this.messageRepository.save(nachricht);
// how can I persist messages and to arrange a chat room.
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getId().intValue() == id.intValue());
When should I use UnicastProcessor when DirectProcessor.
Update:
a little correction
public Flux<Message> finAllMessagesByChatroomId(Long id)
return hotFlux.filter(m->m.getRoom_id == id);
But how can I get all the Messages from the database and add it to fluxSink?
reactive-programming spring-webflux spring-data-r2dbc
reactive-programming spring-webflux spring-data-r2dbc
edited Mar 24 at 22:03
asked Mar 24 at 20:34
user9565938
I see three different questions in the body and the title of your text. Please clarify which you want to be answered and what the exact problem is.
– Jens Schauder
Mar 26 at 6:31
Thank you for your reply. I want to save data in database and if anyone is in the chat room, then he should get messages. I'm very unsure what to do exactly.
– user9565938
Mar 26 at 10:31
add a comment |
I see three different questions in the body and the title of your text. Please clarify which you want to be answered and what the exact problem is.
– Jens Schauder
Mar 26 at 6:31
Thank you for your reply. I want to save data in database and if anyone is in the chat room, then he should get messages. I'm very unsure what to do exactly.
– user9565938
Mar 26 at 10:31
I see three different questions in the body and the title of your text. Please clarify which you want to be answered and what the exact problem is.
– Jens Schauder
Mar 26 at 6:31
I see three different questions in the body and the title of your text. Please clarify which you want to be answered and what the exact problem is.
– Jens Schauder
Mar 26 at 6:31
Thank you for your reply. I want to save data in database and if anyone is in the chat room, then he should get messages. I'm very unsure what to do exactly.
– user9565938
Mar 26 at 10:31
Thank you for your reply. I want to save data in database and if anyone is in the chat room, then he should get messages. I'm very unsure what to do exactly.
– user9565938
Mar 26 at 10:31
add a comment |
0
active
oldest
votes
Your Answer
StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");
StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);
else
createEditor();
);
function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);
);
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55328304%2fhow-to-publish-messages-from-a-room-with-reactive-programming%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55328304%2fhow-to-publish-messages-from-a-room-with-reactive-programming%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
I see three different questions in the body and the title of your text. Please clarify which you want to be answered and what the exact problem is.
– Jens Schauder
Mar 26 at 6:31
Thank you for your reply. I want to save data in database and if anyone is in the chat room, then he should get messages. I'm very unsure what to do exactly.
– user9565938
Mar 26 at 10:31