Use Sink instead of EmitterProcessor

asyncer-io / r2dbc-mysql

Reactive Relational Database Connectivity for MySQL. The official successor to mirromutth/r2dbc-mysql(dev.miku:r2dbc-mysql).

https://r2dbc.io

Apache License 2.0

206 stars 21 forks source link

Closed jchrys closed 1 year ago

jchrys commented 1 year ago

Motivation: EmitterProcessor is deprecated

Modifications: Used Sink to replace deprecated EmitterProcessor

Results: Up-to-date with Reactor