I hereby claim:
- I am jasonmartens on github.
- I am bitmaker (https://keybase.io/bitmaker) on keybase.
- I have a public key ASCmXARz5Cv6euSNVVgwvxeXh8XIJWC_9bltLYepF2ea0Ao
To claim this, I am signing this object:
package com.jasonmartens.s3downloader | |
import akka.actor.Props | |
import akka.http.scaladsl.Http | |
import akka.http.scaladsl.model.headers.{ByteRange, Range} | |
import akka.http.scaladsl.model.{HttpRequest, HttpResponse} | |
import akka.stream.ActorFlowMaterializer | |
import akka.stream.actor.ActorPublisher | |
import akka.stream.actor.ActorPublisherMessage.{Cancel, Request} | |
import akka.stream.scaladsl.Source |
/** | |
* Use the akka-http marshalling system to marshal a case class into json | |
* | |
* @param entity The case class object to marshal | |
* @param m An implicit marshaller to do the conversion | |
* @tparam T The case class type | |
* @return The json representation of the entity | |
*/ | |
def marshalEntity[T](entity: T)(implicit m: Marshaller[T, MessageEntity]): Future[Source[String, Any]] = { | |
// MessageEntity is used as a placeholder to get json as the marshalled value |
/** | |
* Created by jasonmartens on 10/13/15. | |
*/ | |
object Main extends App { | |
import spray.json._ | |
import scala.reflect.ClassTag |
last compile:run | |
[info] Running example.ScalaJSExample | |
[debug] with JSEnv of type class org.scalajs.jsenv.nodejs.NodeJSEnv | |
[debug] with classpath of type class org.scalajs.core.tools.classpath.LinkedClasspath | |
[error] /Users/jasonmartens/test/scala-js-example-app/target/scala-2.11/example-fastopt.js:1765 | |
[error] var paragraph = $g["document"]["createElement"]("p"); | |
[error] ^ | |
[error] | |
[error] TypeError: Cannot read property 'createElement' of undefined | |
[error] at $c_Lexample_ScalaJSExample$.main__V (/Users/jasonmartens/test/scala-js-example-app/target/scala-2.11/example-fastopt.js:1765:33) |
I hereby claim:
To claim this, I am signing this object:
import scalaz.nio._ | |
import scalaz.nio.channels.{AsynchronousServerSocketChannel, AsynchronousSocketChannel} | |
import scalaz.zio.clock.Clock | |
import scalaz.zio.console._ | |
import scalaz.zio.{App, ZIO} | |
object Main extends App { | |
override def run(args: List[String]): ZIO[Environment, Nothing, Int] = | |
myAppLogic | |
.either |
import scalaz.nio._ | |
import scalaz.nio.channels.{AsynchronousServerSocketChannel, AsynchronousSocketChannel} | |
import scalaz.zio.console._ | |
import scalaz.zio.{App, ZIO} | |
object Bracket extends App { | |
override def run(args: List[String]): ZIO[Environment, Nothing, Int] = { | |
theSocket.foldM( |
import scalaz.nio._ | |
import scalaz.nio.channels.{AsynchronousServerSocketChannel, AsynchronousSocketChannel} | |
import scalaz.zio.clock.Clock | |
import scalaz.zio.console._ | |
import scalaz.zio.{App, ZIO, _} | |
object Main extends App { | |
override def run(args: List[String]): ZIO[Environment, Nothing, Int] = { | |
theSocket.foldM( |