I have an API that emits items from time to time. ...

# rx

[tschuchort]

I have an API that emits items from time to time. Unfortunately the API needs to know when I'm finished processing the item (for keeping wake locks), so I can't subscribe directly. Currently it looks like this: fun subscribeNewItems(onNext: (Item) -> Completable). Any ideas how I can make it so I can subscribe directly?