sugamon

## pstest_sample.go
ctx := context.Background()

// Start a fake server running locally.
srv := pstest.NewServer()
defer srv.Close()

// Connect to the server without using TLS.
conn, err := grpc.Dial(srv.Addr, grpc.WithInsecure())
if err != nil {
    // TODO: Handle error.

## pstest_publisher.go
package pubsub

import (
	"context"

	"cloud.google.com/go/pubsub"
	"google.golang.org/api/option"
)

type Publisher struct {

## pstest_publisher_test.go
package pubsub

import (
	"context"
	"testing"

	"cloud.google.com/go/pubsub/pstest"
	"google.golang.org/api/option"
	"google.golang.org/grpc"
)

## pstest_subscriber.go
package pubsub

import (
	"context"
	"fmt"

	"cloud.google.com/go/pubsub"
	"google.golang.org/api/option"
)

## pstest_subscriber_test.go
package pubsub

import (
	"context"
	"testing"
	"time"

	"cloud.google.com/go/pubsub"
	"cloud.google.com/go/pubsub/pstest"
	"google.golang.org/api/option"

## pubsub_apiv1_publisher.go
package pubsub

import (
	"context"

	pubsub "cloud.google.com/go/pubsub/apiv1"
	"google.golang.org/api/option"
	pubsubpb "google.golang.org/genproto/googleapis/pubsub/v1"
)

## pubsub_apiv1_publisher_test.go
package pubsub

import (
	"context"
	"testing"

	"cloud.google.com/go/pubsub/pstest"
	"google.golang.org/api/option"
	pubsubpb "google.golang.org/genproto/googleapis/pubsub/v1"
	"google.golang.org/grpc"

## pubsub_apiv1_subscriber.go
package pubsub

import (
	"context"

	pubsub "cloud.google.com/go/pubsub/apiv1"
	"google.golang.org/api/option"
	pubsubpb "google.golang.org/genproto/googleapis/pubsub/v1"
)

## pubsub_apiv1_subscriber_test.go
package pubsub

import (
	"context"
	"testing"

	"cloud.google.com/go/pubsub/pstest"
	"golang.org/x/xerrors"
	"google.golang.org/api/option"
	pubsubpb "google.golang.org/genproto/googleapis/pubsub/v1"
	ctx := context.Background()

	// Start a fake server running locally.
	srv := pstest.NewServer()
	defer srv.Close()

	// Connect to the server without using TLS.
	conn, err := grpc.Dial(srv.Addr, grpc.WithInsecure())
	if err != nil {
	// TODO: Handle error.
	package pubsub

	import (
	"context"

	"cloud.google.com/go/pubsub"
	"google.golang.org/api/option"
	)

	type Publisher struct {