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;








0















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?










share|improve this question
























  • 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


















0















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?










share|improve this question
























  • 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














0












0








0








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?










share|improve this question
















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






share|improve this question















share|improve this question













share|improve this question




share|improve this question








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


















  • 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













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
);



);













draft saved

draft discarded


















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















draft saved

draft discarded
















































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.




draft saved


draft discarded














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





















































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







Popular posts from this blog

Kamusi Yaliyomo Aina za kamusi | Muundo wa kamusi | Faida za kamusi | Dhima ya picha katika kamusi | Marejeo | Tazama pia | Viungo vya nje | UrambazajiKuhusu kamusiGo-SwahiliWiki-KamusiKamusi ya Kiswahili na Kiingerezakuihariri na kuongeza habari

SQL error code 1064 with creating Laravel foreign keysForeign key constraints: When to use ON UPDATE and ON DELETEDropping column with foreign key Laravel error: General error: 1025 Error on renameLaravel SQL Can't create tableLaravel Migration foreign key errorLaravel php artisan migrate:refresh giving a syntax errorSQLSTATE[42S01]: Base table or view already exists or Base table or view already exists: 1050 Tableerror in migrating laravel file to xampp serverSyntax error or access violation: 1064:syntax to use near 'unsigned not null, modelName varchar(191) not null, title varchar(191) not nLaravel cannot create new table field in mysqlLaravel 5.7:Last migration creates table but is not registered in the migration table

은진 송씨 목차 역사 본관 분파 인물 조선 왕실과의 인척 관계 집성촌 항렬자 인구 같이 보기 각주 둘러보기 메뉴은진 송씨세종실록 149권, 지리지 충청도 공주목 은진현