Skip to content
This repository was archived by the owner on Sep 7, 2022. It is now read-only.
This repository was archived by the owner on Sep 7, 2022. It is now read-only.

Refactor Props's async logic to use Reactive Streams #58

@MihaiBojin

Description

@MihaiBojin

Describe the solution you'd like

  • the current async logic works but is custom
  • there is value in making the interface compatible with org.reactivestreams and especially to support backpressure

Additional context

  • register Subscriber<T> instead of Consumer<T>, Consumer<Throwable>
  • each Prop<T> implements Publisher<T>
  • alternatively examine java.util.concurrent.Flow (and related classes) as a possible interface

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementNew feature or request

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions