rxjs get list of people typing












1















I have a messaging system in my application that uses socket-io to allow users to send instant messages to eachother.



I have a service which detects when they are typing.



const userTyping = this.instantMessageService
.messageTyping;

userTyping.subscribe(message => console.log(message.username))


I want the other users to be able to see a list of who is typing them a message which times out.



So if one person starts typing they will see "John Doe is typing a message" - this will timeout a couple of seconds later.



In the meantime, if another users starts typing they will see "John Doe and Bill Bloggs are typing a message" and so on.



I've tried messing around with merge, window, buffer etc in rxjs but can't seem to tie it all together.



Anyone got any tips?










share|improve this question





























    1















    I have a messaging system in my application that uses socket-io to allow users to send instant messages to eachother.



    I have a service which detects when they are typing.



    const userTyping = this.instantMessageService
    .messageTyping;

    userTyping.subscribe(message => console.log(message.username))


    I want the other users to be able to see a list of who is typing them a message which times out.



    So if one person starts typing they will see "John Doe is typing a message" - this will timeout a couple of seconds later.



    In the meantime, if another users starts typing they will see "John Doe and Bill Bloggs are typing a message" and so on.



    I've tried messing around with merge, window, buffer etc in rxjs but can't seem to tie it all together.



    Anyone got any tips?










    share|improve this question



























      1












      1








      1








      I have a messaging system in my application that uses socket-io to allow users to send instant messages to eachother.



      I have a service which detects when they are typing.



      const userTyping = this.instantMessageService
      .messageTyping;

      userTyping.subscribe(message => console.log(message.username))


      I want the other users to be able to see a list of who is typing them a message which times out.



      So if one person starts typing they will see "John Doe is typing a message" - this will timeout a couple of seconds later.



      In the meantime, if another users starts typing they will see "John Doe and Bill Bloggs are typing a message" and so on.



      I've tried messing around with merge, window, buffer etc in rxjs but can't seem to tie it all together.



      Anyone got any tips?










      share|improve this question
















      I have a messaging system in my application that uses socket-io to allow users to send instant messages to eachother.



      I have a service which detects when they are typing.



      const userTyping = this.instantMessageService
      .messageTyping;

      userTyping.subscribe(message => console.log(message.username))


      I want the other users to be able to see a list of who is typing them a message which times out.



      So if one person starts typing they will see "John Doe is typing a message" - this will timeout a couple of seconds later.



      In the meantime, if another users starts typing they will see "John Doe and Bill Bloggs are typing a message" and so on.



      I've tried messing around with merge, window, buffer etc in rxjs but can't seem to tie it all together.



      Anyone got any tips?







      angular socket.io rxjs angular7 rxjs6






      share|improve this question















      share|improve this question













      share|improve this question




      share|improve this question








      edited Jan 2 at 20:08









      mruanova

      1,79821331




      1,79821331










      asked Jan 1 at 9:04









      shavenwalrusshavenwalrus

      1513




      1513
























          2 Answers
          2






          active

          oldest

          votes


















          0














          You can push the result to an array and map throw it to show who is typing






          share|improve this answer































            0














            Try to use the [reduce][1] and concat the item in the reduce.






            share|improve this answer























              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%2f53994224%2frxjs-get-list-of-people-typing%23new-answer', 'question_page');
              }
              );

              Post as a guest















              Required, but never shown

























              2 Answers
              2






              active

              oldest

              votes








              2 Answers
              2






              active

              oldest

              votes









              active

              oldest

              votes






              active

              oldest

              votes









              0














              You can push the result to an array and map throw it to show who is typing






              share|improve this answer




























                0














                You can push the result to an array and map throw it to show who is typing






                share|improve this answer


























                  0












                  0








                  0







                  You can push the result to an array and map throw it to show who is typing






                  share|improve this answer













                  You can push the result to an array and map throw it to show who is typing







                  share|improve this answer












                  share|improve this answer



                  share|improve this answer










                  answered Jan 2 at 15:22









                  sareasarea

                  436




                  436

























                      0














                      Try to use the [reduce][1] and concat the item in the reduce.






                      share|improve this answer




























                        0














                        Try to use the [reduce][1] and concat the item in the reduce.






                        share|improve this answer


























                          0












                          0








                          0







                          Try to use the [reduce][1] and concat the item in the reduce.






                          share|improve this answer













                          Try to use the [reduce][1] and concat the item in the reduce.







                          share|improve this answer












                          share|improve this answer



                          share|improve this answer










                          answered Mar 1 at 7:56









                          yesterday_timeyesterday_time

                          135




                          135






























                              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%2f53994224%2frxjs-get-list-of-people-typing%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

                              MongoDB - Not Authorized To Execute Command

                              in spring boot 2.1 many test slices are not allowed anymore due to multiple @BootstrapWith

                              How to fix TextFormField cause rebuild widget in Flutter