Implementación naive del punto 1. No sirve para otros puntos porque, por ejemplo, no admite más de una subscripción a la vez. Es sólo para que sepan por dónde empezar si están trabados.

ayudita.scala

package ayudita

object ObservableFactory {
  def create[T](f:(MySubscriber[T])=>Unit): MyObservable[T] = {
    new MyObservable[T](f)
  }
}

class MyObservable[T](val act:(MySubscriber[T])=>Unit) {
  def subscribe(subscriber:MySubscriber[T]) {
    act(subscriber)
  }
}

trait MySubscriber[-T] {
  def onNext(t:T)
  def onError()
  def onCompleted()
}

object Ejemplo extends App {
  val o: MyObservable[Int] = ObservableFactory.create[Int] {
    subscriber =>
      Range(1, 5).foreach(subscriber.onNext)
      subscriber.onCompleted()
  }

  println("Recien ahora se emiten elementos")

  o.subscribe(new MySubscriber[Int] {
    override def onError(): Unit = println("Error")

    override def onCompleted(): Unit = println("Completado")

    override def onNext(t: Int): Unit = println(s"Evento $t")
  })
}