{"id":5264,"date":"2024-10-14T13:44:16","date_gmt":"2024-10-14T13:44:16","guid":{"rendered":"https:\/\/codethataint.com\/blog\/?p=5264"},"modified":"2024-10-15T04:36:49","modified_gmt":"2024-10-15T04:36:49","slug":"reactive-programming-io-models","status":"publish","type":"post","link":"https:\/\/codethataint.com\/blog\/reactive-programming-io-models\/","title":{"rendered":"Reactive Programming IO Models"},"content":{"rendered":"

Communication Models<\/strong><\/p>\n

    \n
  1. Synchronous + Blocking – Calling Customer Service and waiting for response online<\/li>\n
  2. Asynchronous- Asking My Friend to Call Customer Service and I carry forward with my work<\/li>\n
  3. Non-Blocking- Asking Call back from Customer Service and I carry forward with my work<\/li>\n
  4. Asynchronous + Non Blocking – I am Calling customer Service and asking to call back My Friend and I carry forward with my work<\/li>\n<\/ol>\n

    request -> response
    \nrequest -> streaming response (Stock Price in Stock Market App, Heart Beat for Health Check in Spring Boot Appp)
    \nstreaming request -> response (Using Google Docs and updating in drive in regular time intervals)
    \nstreaming request -> streaming response (Playing Game Online)<\/p>\n

    Reactive Stream Specification<\/strong>
    \nProcess Stream of Messages in a Non Blocking Asynchronous manner with Observer Design Pattern(Observe and React incase of change) <\/p>\n

      \n
    1. Publisher:<\/strong> Emits a sequence of elements to its subscribers.\n
      \r\nvoid subscribe(Subscriber<? super T> s)\r\n<\/pre>\n<\/li>\n
    2. Subscriber:<\/strong> Consumes elements provided by a Publisher.\n
      \r\nvoid onSubscribe(Subscription s)\r\nvoid onNext(T t)\r\nvoid onError(Throwable t)\r\nvoid onComplete()\r\n<\/pre>\n<\/li>\n
    3. Subscription:<\/strong> Represents a one-to-one lifecycle of a Subscriber subscribing to a Publisher.\n
      \r\nvoid request(long n)\r\nvoid cancel()\r\n<\/pre>\n<\/li>\n
    4. Processor: Represents a processing stage, which is both a Subscriber and a Publisher.Inherits both Subscriber and Publisher interfaces.<\/li>\n<\/ol>\n
      There would be one Publisher at Top, similar to root of tree and there would be 0 to N intermediate processors(subscriber + publisher) and there would be leaf Subscriber
      \n\"\"<\/p>\n
      Publisher, Subscriber and Subscription<\/strong><\/p>\n
      \r\npublic interface Publisher<T> {\r\n   public void subscribe(Subscriber<? super T> s);\r\n}\r\n<\/pre>\n
      \r\npublic interface Subscription {\r\n   public void request(long n);\r\n   public void cancel();\r\n}\r\n<\/pre>\n
      \r\npublic interface Subscriber<T> {\r\n   public void onSubscribe(Subscription s);\r\n   public void onNext(T t);\r\n   public void onError(Throwable t);\r\n   public void onComplete();\r\n}\r\n<\/pre>\n
        \n
      1. Publisher will have subscribe method through which we would pass the subscriber instance. The Subscription object would be returned by Publisher <\/li>\n
      2. The Publisher hands over subscription object to Subscriber. Subscriber uses onSubscribe method to accept subscription. <\/li>\n
      3. Subscriber could use subscription object using request method and could cancel subscription. Communication between Publisher and Subscriber happens using subscription object<\/li>\n
      4. Subscriber can request N items using subscription object. The Publisher can iterate to N object using onNext method. Publisher only give 3 items if 3 items is requested by subscriber.<\/li>\n
      5. If the Publisher has completed transferring all Items, then Publisher can call onComplete() method in Subscriber to notify the subscriber that its work is done<\/li>\n
      6. Publisher calls onError() method to notify error.<\/li>\n<\/ol>\n
        \"\"<\/p>\n
        \"\"<\/p>\n","protected":false},"excerpt":{"rendered":"
        Communication Models Synchronous + Blocking – Calling Customer Service and waiting for response online Asynchronous- Asking My Friend to Call Customer Service and I carry forward with my work Non-Blocking- Asking Call back from Customer Service and I carry forward with my work Asynchronous + Non Blocking – I am Calling customer Service and asking… Continue reading →<\/span><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[369],"tags":[],"class_list":["post-5264","post","type-post","status-publish","format-standard","hentry","category-reactive-programming"],"_links":{"self":[{"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/posts\/5264","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/comments?post=5264"}],"version-history":[{"count":5,"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/posts\/5264\/revisions"}],"predecessor-version":[{"id":5278,"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/posts\/5264\/revisions\/5278"}],"wp:attachment":[{"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/media?parent=5264"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/categories?post=5264"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/codethataint.com\/blog\/wp-json\/wp\/v2\/tags?post=5264"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}