subscribeTo

@CheckResult()
abstract fun subscribeTo(onUserAvailable: Consumer<UserProcessor.Input.User>): Closeable
Content copied to clipboard

Subscribes to the provided onUserAvailable to be notified when a new User is available for this input. The returned Closeable must be closed when done working with this input otherwise underlying resources will be leaked.