Как реализовать шаблон железной дороги в Kotlin/Arrow.kt для продюсерского канала

Вы можете использовать от Arrow-kt.

Вы можете использовать Either's mapLeft(), map(), flatMap().

Если результат Exception, используйте mapLeft(). Возвращаемое значение из mapLeft() будет новым Left в результате Either, например, возврат будет String, результатом будет Either<String, List<Any>>. В случае, если результат Right, т.е. List<Any>, mapLeft() будет пропущен, но тип результата все равно изменится, поэтому у вас будет тип Either<String, List<Any>> со значением Right<List<Any>>. Вы также можете вернуть тот же Exception из mapLeft(), если вы так выберете

В случае, если вам не нужно обрабатывать определенные ошибки, вы можете просто связать map() и flatMap(). map() в основном является mapRight(), а flatMap() полезен, когда вы хотите цепочку вызовов, т. е. где-то в цепочке есть получатель List<Any>, который может дать сбой, и вы хотите обрабатывать Exception таким же образом с Either для этого вызова, вы можете просто вернуть новый Either из flatMap()

Код будет выглядеть примерно так

fun perform(action: Either<Exception, Action>): ReceiveChannel<List<Any>> =
    produce {
        // if action is always right, you can start it as Right(action) but then first mapLeft does not make any sense
        if (historical.completed) action
            .mapLeft {
                // handle actions exception here
                // transform it to something else or just return it
                send(action.sideEffects)
                it
            }.flatMap {
                // handle right side of action either
                // assume here that repository may fail and returns Either<Exception, NetworkResponse>
                repository.perform(it)
            }.mapLeft {
                // handle repositorys exception here
                // transform it to something else or just return it
                send(it)
                it
            }.map {
                // handle network response
                send(listOf(networkResponse))
                historical.complete(listOf(networkResponse))
            }
    }