fizzbuz-cloudflow-ingress-streamlet.scala

package fizzbuzz

import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._

import cloudflow.akkastream._
import cloudflow.akkastream.util.scaladsl._

import cloudflow.streamlets._
import cloudflow.streamlets.avro._

import JsonFormats._

class FizzBuzzNumberHttpIngress extends AkkaServerStreamlet {

  val out = 
    AvroOutlet[FizzBuzzNumber]( "out" ).withPartitioner( RoundRobinPartitioner )
    
  def shape = StreamletShape.withOutlets( out )
  
  override def createLogic = HttpServerLogic.default( this, out )

}