Application protocol providing Reactive Streams semantics