Method close

worker/import.go:114–121

()

}

func (ps *pubSub) close() {
	ps.Lock()
	defer ps.Unlock()
	for _, ch := range ps.subscribers {
		close(ch)
	}
	ps.subscribers = nil
}

func (ps *pubSub) handlePublisher(ctx context.Context, stream api.Dgraph_StreamExtSnapshotServer) error {
	for {