nraychaudhuri

package samples

import akka.stream.scaladsl.Flow
import akka.stream.{MaterializerSettings, FlowMaterializer}
import org.reactivestreams.api.{Consumer, Producer}
import org.reactivestreams.spi.{Subscription, Subscriber}
import akka.actor.ActorSystem

object OneProducerManySubscribers {

nraychaudhuri

object AuthenticatedCookie extends CookieBaker[AuthenticatedCookie] {

  val COOKIE_NAME = "AUTHENTICATED_COOKIE"

  val emptyCookie = new AuthenticatedCookie

  def deserialize(data: Map[String, String]) = new AuthenticatedCookie(data)
  def serialize(cookie: AuthenticatedCookie) = cookie.data

  def cookie(rh: RequestHeader): AuthenticatedCookie = decodeFromCookie(rh.cookies.get(COOKIE_NAME))

nraychaudhuri

package controllers;

import com.fasterxml.jackson.databind.ObjectMapper;
import models.Computer;
import play.mvc.*;
import play.data.Form;
import java.util.Map;


public class Application extends Controller {

nraychaudhuri

Getting Started with Scala

What is Scala?

Scala is a general-purpose programming language designed to express common programming patterns in a concise, elegant, and type-safe way. It smoothly integrates features of object-oriented and functional programming languages, enabling programmers to be more productive. Scala is an acronym for “Scalable Language”. This means that Scala grows with you.

Create a new Scala project using Activator

nraychaudhuri

package controllers

import play.api.mvc._
import scala.concurrent._
import akka.actor.{Props, Actor}
import play.api.Play.current
import play.api.libs.concurrent.Akka
import scala.concurrent.ExecutionContext.Implicits._

object Application extends Controller {

nraychaudhuri

    val factory = new org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory(
      new NioServerBossPool(Executors.newCachedThreadPool(NamedThreadFactory("play-netty-boss")), 1, ThreadNameDeterminer.CURRENT),
      new NioWorkerPool(Executors.newCachedThreadPool(NamedThreadFactory("play-netty-worker")),
        Runtime.getRuntime.availableProcessors * 2,
        ThreadNameDeterminer.CURRENT)
    )

nraychaudhuri

  //instead of using WS.url("http://www.google.com") use new CustomRequestHeader(url)   
  
  
  
  class CustomRequestHolder extends WSRequestHolder {

    public CustomRequestHolder(String url) { super(url); }
    
    @Override
    public Promise<Response> execute(String method) {

nraychaudhuri

package controllers

import play.api._
import play.api.mvc._
import play.api.mvc.Controller

object Application {

  def index = Action {
    Results.Ok(views.html.index("Your new application is ready."))

nraychaudhuri

package controllers;

import java.io.File;
import java.util.List;

import play.mvc.BodyParser;
import play.mvc.BodyParser.Of;
import play.mvc.Controller;
import play.mvc.Http.MultipartFormData;
import play.mvc.Http.MultipartFormData.FilePart;

nraychaudhuri

  
  
  case class Speaker(name: String, bio: String, twitterId: Option[String], id: Option[Long] = None)

  class Speakers extends Table[Speaker]("Speaker") {
    def id = column[Long]("id", O.PrimaryKey, O.AutoInc)
    def name = column[String]("name")
    def bio = column[String]("bio")
    def twitterId = column[Option[String]]("twitterId")