marioosh

package com.howtographql.scala.sangria\

import DBSchema._
import com.howtographql.scala.sangria.models.{Link, User, Vote}
import slick.jdbc.H2Profile.api._

import scala.concurrent.Future

class DAO(db: Database) {
  def allLinks = db.run(Links.result)

marioosh

package com.howtographql.scala.sangria

import com.howtographql.scala.sangria.models.Authorized
import sangria.execution.{Middleware, MiddlewareBeforeField, MiddlewareQueryContext}
import sangria.schema.Context

object AuthMiddleware extends Middleware[MyContext] with MiddlewareBeforeField[MyContext] {
  override type QueryVal = Unit
  override type FieldVal = Unit

marioosh

package com.howtographql.scala.sangria
import DBSchema._
import com.howtographql.scala.sangria.models.{AuthProviderSignupData, Link, User, Vote}
import sangria.execution.deferred.{RelationIds, SimpleRelation}
import slick.jdbc.H2Profile.api._

import scala.concurrent.Future

class DAO(db: Database) {
  def allLinks = db.run(Links.result)

marioosh

package com.howtographql.scala.sangria

import java.sql.Timestamp

import akka.http.scaladsl.model.DateTime
import com.howtographql.scala.sangria.models._
import slick.jdbc.H2Profile.api._

import scala.concurrent.duration._
import scala.concurrent.Await

marioosh

package com.howtographql.scala.sangria
import DBSchema._
import com.howtographql.scala.sangria.models.{Link, User, Vote}
import sangria.execution.deferred.{RelationIds, SimpleRelation}
import slick.jdbc.H2Profile.api._

import scala.concurrent.Future

class DAO(db: Database) {
  def allLinks = db.run(Links.result)

marioosh

< 6 7 0 > - H: HunterHeavy-1.2.0 A: HunterHeavy-2.1.0 C: HunterHeavy-1.3.0 L: HunterHeavy-2.1.0
< 6 6 1 > - H: HunterHeavy-1.2.0 A: HunterHeavy-2.1.0 C: HunterHeavy-1.2.1 L: HunterHeavy-2.1.0
< 6 6 1 > - H: HunterHeavy-1.1.1 A: HunterHeavy-2.1.0 C: HunterHeavy-1.3.0 L: HunterHeavy-2.1.0
< 6 5 2 > - H: HunterHeavy-1.1.1 A: HunterHeavy-2.1.0 C: HunterHeavy-1.2.1 L: HunterHeavy-2.1.0
< 5 8 0 > - H: HunterHeavy-1.2.0 A: HunterHeavy-2.1.0 C: HunterHeavy-1.3.0 L: HunterHeavy-1.2.0
< 5 8 0 > - H: HunterHeavy-1.2.0 A: HunterHeavy-1.2.0 C: HunterHeavy-1.3.0 L: HunterHeavy-2.1.0
< 5 7 1 > - H: HunterHeavy-1.2.0 A: HunterHeavy-2.1.0 C: HunterHeavy-1.2.1 L: HunterHeavy-1.2.0
< 5 7 1 > - H: HunterHeavy-1.2.0 A: HunterHeavy-1.2.0 C: HunterHeavy-1.2.1 L: HunterHeavy-2.1.0
< 5 7 1 > - H: HunterHeavy-1.1.1 A: HunterHeavy-2.1.0 C: HunterHeavy-1.3.0 L: HunterHeavy-1.2.0
< 5 7 1 > - H: HunterHeavy-1.1.1 A: HunterHeavy-1.2.0 C: HunterHeavy-1.3.0 L: HunterHeavy-2.1.0

marioosh

Caused by: : /projekty/intellij-elixir/intellij-elixir-gradle/src/main/java/org/elixir_lang/configuration/ElixirCompilerOptionsConfigurable.form: The form is bound to the class org.elixir_lang.configuration.ElixirCompilerOptionsConfigurable.
Another form /projekty/intellij-elixir/intellij-elixir-gradle/src/main/java/org/elixir_lang/configuration/ElixirCompilerOptionsConfigurable.form is also bound to this class.
	at com.intellij.ant.Javac2.fireError(Javac2.java:510)
	at com.intellij.ant.Javac2.instrumentForms(Javac2.java:297)
	at com.intellij.ant.Javac2.compile(Javac2.java:236)
	at org.apache.tools.ant.taskdefs.Javac.execute(Javac.java:936)
	at org.apache.tools.ant.UnknownElement.execute(UnknownElement.java:293)
	at org.apache.tools.ant.dispatch.DispatchUtils.execute(DispatchUtils.java:106)
	at org.gradle.api.internal.project.ant.BasicAntBuilder.nodeCompleted(BasicAntBuilder.java:78)
	at org.gradle.api.internal.project.ant.BasicAntBuilder.doInvokeMethod(BasicAntBuilder.java:93)

marioosh

package io.scalac.conductr.example

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Directives._
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Sink, Source}

import scala.concurrent.duration._
import scala.concurrent.{Await, Future}

marioosh

val source = Source(1 to 10)

val sink = Sink.fold[String, String]("")(_ + _)

val flow = Flow[Int]
               .filter(_ % 2 == 0)
               .map(_.toString)
               
val result = source.via(flow).runWith(sink)    //Future[String]

marioosh

class ChatRoom(roomId: Int, actorSystem: ActorSystem) {

  private[this] val chatRoomActor = actorSystem.actorOf(Props(classOf[ChatRoomActor], roomId))

  def websocketFlow(user: String): Flow[Message, Message, _] = ???

  def sendMessage(message: ChatMessage): Unit = chatRoomActor ! message

}