Как реализовать Lazy Chain Pattern в Scala - PullRequest
Новая
       20

Как реализовать Lazy Chain Pattern в Scala

0 голосов
/ 14 февраля 2019

Я пытаюсь определить набор «LazyChains», который будет использоваться для обработки входящих сообщений в будущем.Я хочу, чтобы API-интерфейс LazyChains был неотличим от API-интерфейсов коллекций Scala (например, Seq, Stream и т. Д.).Это позволило бы мне декларативно определять фильтрацию / преобразования / действия заранее, до того, как приходят сообщения.Вполне возможно, что это хорошо известный шаблон, имя которого я не знаю, поэтому мне трудно найти какие-либо результаты по этому вопросу.

Это пример того, что я пытаюсьдля выполнения: 

val chainA = LazyChain()
 .filter(_ > 1)
 .map(x => x * 2)
 .foreach(println _)

val chainB = LazyChain()
 .filter(_ > 5)
 .flatMap(x => Seq(x, x))
 .foreach(println _)

 chainA.apply(2)  // should print "4"
 chainA.apply(1)  // should print nothing
 chainB.apply(10) // should print "10" - twice

Этот шаблон уже существует в API коллекций Scala?Если нет, то как я могу реализовать этот класс LazyChain?

Это моя текущая попытка сделать это.Я не могу понять, как заставить типы работать: 

case class LazyChain[I, O](val filter : Option[I => Boolean],
                      val transform : I => O,
                      val action : Option[O => Unit]) {

  def filter(otherFilter : I => Boolean): LazyChain[I, O]  = {
      val newFilter = Some({ x : I => {
        filter.map(_.apply(x)).getOrElse(true) && otherFilter.apply(x)
      }})
      copy(filter = newFilter)
  }

  def map[X](otherTransform : O => X) : LazyChain[I, X] = {
    new LazyChain[I, X](
      filter = filter,
      transform = (x: I) => {
        otherTransform.apply(transform.apply(x))
      },
      /*
        type mismatch;
        [error]  found   : Option[O => Unit]
        [error]  required: Option[X => Unit]
      */
      action = action 
    )
  }

  def flatMap[X](otherTransform : O => Seq[X]) : LazyChain[I, X] = {
    new LazyChain[I, X](
      filter = filter,
      transform = (x: I) => {
        /**
           type mismatch;
             [error]  found   : Seq[X]
             [error]  required: X
        */
        otherTransform.apply(transform.apply(x))
      }
    )
  }

  def foreach(newAction : O => Unit) = {
    copy(action = Some(newAction))
  }

  def apply(element : I) = {
    if (filter.map(_.apply(element)).getOrElse(true)) {
      val postTransform = transform.apply(element)
      action.foreach(_.apply(postTransform))
    }
  }
}
object LazyChain {
  def apply[X]() : LazyChain[X, X] = {
    new LazyChain(filter = None, transform = x => x, action = None)
  }
}

1 Ответ

0 голосов
/ 14 февраля 2019

Все, что вам нужно - это обернуть функцию I => List[O] некоторыми причудливыми методами.Вы можете написать свой implicit class, чтобы добавить эти методы к этому типу, но Kleisli делает большую часть этого бесплатно, через различные классы кошачьих типов, в основном FilterFunctor. 

  import cats.implicits._
  import cats.data.Kleisli

  type LazyChain[I, O] = Kleisli[List, I, O]
  def lazyChain[A]: LazyChain[A, A] = Kleisli[List, A, A](a => List(a))

  val chainA = lazyChain[Int]
    .filter(_ > 1)
    .map(x => x * 2)
    .map(println)

  val chainB = lazyChain[Int]
    .filter(_ > 5)
    .flatMapF(x => List(x, x))
    .map(println)

  chainA(2)  // should print "4"
  chainA(1)  // should print nothing
  chainB(10) // should print "10" - twice

Это может выглядеть слишкомВолшебная, так что вот версия ручной работы: 

case class LazyChain[A, B](run: A => List[B]) {

  def filter(f: B => Boolean): LazyChain[A, B] = chain(_.filter(f))

  def map[C](f: B => C): LazyChain[A, C] = chain(_.map(f))

  def flatMap[C](f: B => List[C]): LazyChain[A, C] = chain(_.flatMap(f))

  def chain[C](f: List[B] => List[C]): LazyChain[A, C] = LazyChain(run andThen f)
}
object LazyChain {
  def apply[I]: LazyChain[I, I] = new LazyChain(a => List(a))
}

Преобразование в цепочку является общей проблемой, и, как говорится в комментариях, использование чего-то вроде monix.Observable, iteratees и т. д. является правильным способом решения этой проблемы (вместо простого List и потоки естественно ленивы.

...