Skip to content

Instantly share code, notes, and snippets.

View rocketpages's full-sized avatar

Kevin Webber rocketpages

63 followers · 6 following
View GitHub Profile
@rocketpages
rocketpages / keybase.md
Created August 8, 2017 19:21

Keybase proof

I hereby claim:

  • I am rocketpages on github.
  • I am kvnwbbr (https://keybase.io/kvnwbbr) on keybase.
  • I have a public key whose fingerprint is 186C 1201 E03B 45FB ABB3 AEDA 3082 1DF1 9D92 7F5B

To claim this, I am signing this object:

@rocketpages
rocketpages / SyncPlayAction.scala
Created December 25, 2016 04:57
def index = Action { implicit request =>
Ok(...)
}
@rocketpages
rocketpages / AsyncPlayAction.scala
Created December 25, 2016 04:57
def index = Action.async { implicit request =>
Future(Ok(...))
}
@rocketpages
rocketpages / AsyncShoppingCartAction.java
Created December 25, 2016 04:56
Async Shopping Cart Example
public CompletionStage<Result> index() {
Form<CheckoutForm> checkoutForm = formFactory.form(CheckoutForm.class);
CompletionStage<Cart> cartFuture = CompletableFuture.supplyAsync(() -> cartService.getCartForUser(), ec.current());
return cartFuture.thenApply(cart -> ok(index.render(cart, checkoutForm)));
}
@rocketpages
rocketpages / flight-delay-output.txt
Created March 3, 2016 21:52
Delays for carrier HA: 18 average mins, 18736 delayed flights
Delays for carrier DL: 27 average mins, 209018 delayed flights
Delays for carrier FL: 31 average mins, 117632 delayed flights
Delays for carrier 9E: 32 average mins, 90601 delayed flights
Delays for carrier OH: 34 average mins, 96154 delayed flights
Delays for carrier B6: 42 average mins, 83202 delayed flights
Delays for carrier EV: 35 average mins, 122751 delayed flights
Delays for carrier AQ: 12 average mins, 1908 delayed flights
Delays for carrier MQ: 35 average mins, 205765 delayed flights
Delays for carrier CO: 34 average mins, 141680 delayed flights
@rocketpages
rocketpages / FlightDelays.scala
Created March 3, 2016 19:07
// @formatter:off
val g = RunnableGraph.fromGraph(GraphDSL.create() {
implicit builder =>
import GraphDSL.Implicits._
// Source
val A: Outlet[String] = builder.add(Source.fromIterator(() => flightDelayLines)).out
// Flows
val B: FlowShape[String, FlightEvent] = builder.add(csvToFlightEvent)
@rocketpages
rocketpages / LinearFlow.scala
Last active February 16, 2021 07:01
Demonstrating a basic linear data flow using Akka Streams
import akka.actor.ActorSystem
import akka.stream._
import akka.stream.scaladsl._
// implicit actor system
implicit val system = ActorSystem("Sys")
// implicit actor materializer
implicit val materializer = ActorMaterializer()
@rocketpages
rocketpages / DroppyStream.scala
Created August 23, 2015 21:06
// return the freshest element when there's capacity downstream, drop everything else
val droppyStream: Flow[Message, Message] =
Flow[Message].conflate(seed = identity)((lastMessage, newMessage) => newMessage)
@rocketpages
rocketpages / Decider.scala
Created August 23, 2015 18:35
val decider: Supervision.Decider = exc => exc match {
case _: ArithmeticException => Supervision.Resume
case _ => Supervision.Stop
}
// ActorFlowMaterializer takes the list of transformations comprising a akka.stream.scaladsl.Flow
// and materializes them in the form of org.reactivestreams.Processor
implicit val mat = ActorFlowMaterializer(
ActorFlowMaterializerSettings(system).withSupervisionStrategy(decider))
val source = Source(0 to 5).map(100 / _)
val result = source.runWith(Sink.fold(0)(_ + _))
@rocketpages
rocketpages / KafkaStreaming.scala
Created August 22, 2015 02:46
implicit val actorSystem = ActorSystem("ReactiveKafka")
implicit val materializer = ActorMaterializer()
val kafka = new ReactiveKafka(host = "localhost:9092", zooKeeperHost = "localhost:2181")
val publisher = kafka.consume("lowercaseStrings", "groupName", new StringDecoder())
val subscriber = kafka.publish("uppercaseStrings", "groupName", new StringEncoder())
// consume lowercase strings from kafka and publish them transformed to uppercase
Source(publisher).map(_.toUpperCase).to(Sink(subscriber)).run()