Jonathan Amsterdam jba

jba / pubsub.go

Created August 28, 2017 13:06

attempt to repro https://github.com/GoogleCloudPlatform/google-cloud-go/issues/740

	// Tool to publish messages at intervals, or receive messages.
	package main

	import (
	"flag"
	"fmt"
	"log"
	"os"
	"sync/atomic"
	"time"

jba / refused-stream.go

Created July 11, 2017 20:06

jba / sub1.go

Last active November 14, 2017 10:17

Using the low-level pubsub client to handle one message at a time

	// sub1 receives one message at a time from a subscription.
	package main

	import (
	"context"
	"flag"
	"log"
	"math/rand"
	"time"