val inflow = flow {
      //执行体内部也可以调用其他挂起函数
      (1..3).forEach {
          emit(it)
          delay(100)
      }
      throw NullPointerException()
  }.catch { t: Throwable ->
      //直接调用catch进行异常捕获,这个只能捕获上游的异常
      log(t)
      //尽管是 catch中，也可以使用 emit 重新生产新元素出来
      emit(10)
  }.onCompletion {//流完成时执行逻辑，可以使用 onCompletion,类似 try catch finally中的finally，无论前面是否有异常，都会被调用
      log("onCompletion")
  }

  GlobalScope.launch {
      //设定运行时所使用的调度器，这个只会对他之前的的操作有影响，
      inflow.flowOn(Dispatchers.Default).collect {
          //最终消费 intFlow 需要调用 collect 函数，这个函数也是一个挂起函数
          log(it)
      }
      //可以进行重复消费
      inflow.flowOn(Dispatchers.IO).collect {
          log(it)
      }
  }.join()

val channelFlow = channelFlow {
    send(6)
    log(4)
    withContext(Dispatchers.Default) {
        send(2)
        log(2)
    }
}
channelFlow.collect()