Skip to content

Instantly share code, notes, and snippets.

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(
@jasonmartens
jasonmartens / zio_socket_server.scala
Created June 17, 2019 17:35
Experimenting with ZIO & sockets
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] =
myAppLogic
.either

Keybase proof

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:

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)
/**
* Created by jasonmartens on 10/13/15.
*/
object Main extends App {
import spray.json._
import scala.reflect.ClassTag
@jasonmartens
jasonmartens / couchbaseOps.scala
Created July 31, 2015 23:53
akka-http and Couchbase interop
/**
* 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
@jasonmartens
jasonmartens / ChunkPublisher.scala
Last active November 30, 2016 18:25
Akka Large File Downloader Hangs
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