return new AbstractIterator<E>() {
          final Iterator<? extends E> itr1 = set1.iterator();
          final Iterator<? extends E> itr2 = set2.iterator();

          @Override
          @CheckForNull
          protected E computeNext() {
            if (itr1.hasNext()) {
              return itr1.next();
            }
            while (itr2.hasNext()) {
              E e = itr2.next();

        return new AbstractIterator<E>() {
          final Iterator<? extends E> itr1 = set1.iterator();
          final Iterator<? extends E> itr2 = set2.iterator();

          @Override
          @CheckForNull
          protected E computeNext() {
            if (itr1.hasNext()) {
              return itr1.next();
            }
            while (itr2.hasNext()) {
              E e = itr2.next();

    }
  }

  void VerifyFDefEdges(
      const tensorflow::FunctionDef& fdef,
      const std::vector<EdgeSpec>& e_edges,  // expected edges
      const std::vector<EdgeSpec>& c_edges,  // expected ctrl edges
      bool is_exact_edges = true) {
    // Build a set of edges from fdef
    std::set<EdgeSpec> a_edges;  // actual edges
    // Get edges from inputs to body nodes and between body nodes

	if err != nil {
		t.Fatal(err)
	}
	qs := qsComplete(qsc, 1)
	counter.Add(1) // account for main activity of the goroutine running this test
	ctx1 := context.Background()
	pZero := func() *int32 { var zero int32; return &zero }
	// counts of calls to the QueueNoteFns
	queueNoteCounts := map[int]map[bool]*int32{
		1: {false: pZero(), true: pZero()},

	CLOCK_MONOTONIC               = 0xa
	CLOCK_PROCESS_CPUTIME_ID      = 0xb
	CLOCK_REALTIME                = 0x9
	CLOCK_THREAD_CPUTIME_ID       = 0xc
	CR0                           = 0x0
	CR1                           = 0x100
	CR2                           = 0x200
	CR3                           = 0x300
	CRDLY                         = 0x300
	CREAD                         = 0x80
	CS5                           = 0x0

	CLOCK_PROF                    = 0x2
	CLOCK_REALTIME                = 0x3
	CLOCK_THREAD_CPUTIME_ID       = 0x2
	CLOCK_VIRTUAL                 = 0x1
	CR0                           = 0x0
	CR1                           = 0x200
	CR2                           = 0x400
	CR3                           = 0x600
	CRDLY                         = 0x600
	CREAD                         = 0x80

	CLOCK_UPTIME_RAW_APPROX                 = 0x9
	CLONE_NOFOLLOW                          = 0x1
	CLONE_NOOWNERCOPY                       = 0x2
	CR0                                     = 0x0
	CR1                                     = 0x1000
	CR2                                     = 0x2000
	CR3                                     = 0x3000
	CRDLY                                   = 0x3000

    fi
}

function print_success {
if [[ "${START_MODE}" != "kubeletonly" ]]; then
  if [[ "${ENABLE_DAEMON}" = false ]]; then
    echo "Local Kubernetes cluster is running. Press Ctrl-C to shut it down."
  else
    echo "Local Kubernetes cluster is running."
  fi

  echo
  echo "Configurations:"
  for f in "${TMP_DIR}"/*; do
    echo "  ${f}"
  done

  cat <<EOF

			{"", 3, 0, 24, 0, 0, "", ""},
			{"", 3, 0, 25, 0, 0, "", ""},
			{"", 3, 0, 26, 0, 0, "", ""},
			{"", 3, 0, 27, 0, 0, "", ""},
			{"", 3, 0, 28, 0, 0, "", ""},
			{"", 3, 0, 29, 0, 0, "", ""},
			{"crt1.c", 4, 0, 65521, 0, 0, "", ""},
			{"/usr/src/lib/csu/i386-elf/crti.S", 4, 0, 65521, 0, 0, "", ""},
			{"<command line>", 4, 0, 65521, 0, 0, "", ""},
			{"<built-in>", 4, 0, 65521, 0, 0, "", ""},

result = channel.queue_declare(exclusive=False)
queue_name = result.method.queue

channel.queue_bind(exchange='bucketevents',
                   queue=queue_name)

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
    print(" [x] %r" % body)

channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=False)