Skip to content

Commit cf09f74

Browse files
author
Stephane Maldini
committed
Precise Processor behaviors
1 parent 0d11049 commit cf09f74

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

README.md

+5-1
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,11 @@ public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {
124124
}
125125
````
126126
127-
- A Processor represents a processing stage—which is both a `Subscriber` and a `Publisher` and obeys the contracts of both.
127+
- A `Processor` represents a processing stage—which is both a `Subscriber` and a `Publisher` and obeys the contracts of both.
128+
- A `Processor` must cancel its upstream Subscription if its last downstream Subscription has been cancelled
129+
- A `Processor` must immediately pass on `onError` events received from its upstream to its downstream
130+
- A `Processor` must be prepared to receive incoming elements from its upstream even if a downstream subscriber has not
131+
requested anything yet
128132
129133
### Asynchronous vs Synchronous Processing ###
130134

0 commit comments

Comments
 (0)