This repository has been archived by the owner on Feb 13, 2020. It is now read-only.

switchOnError operator #22

Open

jcornaz opened this issue May 12, 2018 · 0 comments

Labels

feature need-usecase

Owner

jcornaz commented May 12, 2018 •

edited

Loading

Possible implementation:

fun <E> switchOnError(logError: (Throwable) -> Unit = {}, openChannel: () -> ReceiveChannel<E>): ReceiveChannel<E> = produce(Unconfined) {
  while(isActive) {
	try {
		openChannel().consumeEach { send(it) }
	} catch(t: Throwable) {
		logError(t)
	}
  }
}

jcornaz added the feature label

jcornaz added the need-usecase label

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.