Reactive client wrapper for Google PubSub java library.
For use with Akka via custom Source and removal of nulls which are not supported in Akka.
import com.google.api.services.pubsub
import akka.stream._
import akka.stream.scaladsl._
implicit val system = ActorSystem("reactive-pubsub")
implicit val materializer = ActorMaterializer()
val pullRequest = PullRequest(10, false)
ReactivePubsub("testing", "http://localhost:8430") // Emulator at locahost.
.subscribeConcat("projects/myproject/subscriptions/mysubscription", pullRequest)
.map(msg => data.toString)
.runWith(Sink.foreach(println))
Use emulator on locahost.