고양이 효과에서 시프트 기능 사용

고양이 효과 이동 기능을 사용하여 비동기 코드를 실행하려고합니다.고양이 효과에서 시프트 기능 사용

기능 구현 :

def asyncSendMsg(producer: KkProducer)(record: KkRecord) : IO[Either[String, RecordMetadata]] = 
    for { 
     res <- trySendMsg(producer)(record).shift(BlockingFileIO).shift(Main) 
    } yield(res) 

    def trySendMsg(producer: KkProducer)(record: KkRecord): IO[Either[String, RecordMetadata]] = 
    IO { 
     try { 
     Right(producer.send(record).get()) 
     } catch { 
     case e: Exception => Left(e.getMessage()) 
     } 
    }

컴파일하려고, 나는 나타납니다

[error] /home/developer/Desktop/scala/PureProducer/src/main/scala/TheProducer.scala:51:43: value shift is not a member of cats.effect.IO[Either[String,org.apache.kafka.clients.producer.RecordMetadata]] 
[error]  res <- trySendMsg(producer)(record).shift(BlockingFileIO).shift(Main) 
[error]           ^
[error] one error found 
[error] (compile:compileIncremental) Compilation failed 
[error] Total time: 2 s, completed Nov 13, 2017 2:18:06 PM

어떤 라이브러리 내가 이동 기능을 사용하기 위해 수입해야합니까?

val nonBlockingExecContext = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)) 

val res = for { 
    _ <- IO { println(Thread.currentThread().getName) } 
    _ <- IO.shift(nonBlockingExecContext) 
    _ <- IO { println(Thread.currentThread().getName) } 
} yield() 

res.unsafeRunSync()

수익률 :

출처

2017-11-13 zero_coding