Remove old code.

Author: balhoff

src/main/scala/org/renci/relationgraph/Main.scala

@@ -71,15 +71,13 @@ object Main extends ZCaseApp[Config] {
           restrictionsStream = Stream.fromQueue(queue).map(r => processRestrictionAndExtendQueue(r, classes, whelk, config.mode, queue, activeRestrictions))
           allTasks = classesTasks ++ restrictionsStream
           processed = allTasks.mapMParUnordered(JRuntime.getRuntime.availableProcessors)(identity)
-          //watchFiber <- activeRestrictions.changes.dropUntil(_.isEmpty).take(1).foreach(_ => queue.shutdown).fork
           _ <- processed.foreach {
             case TriplesGroup(nonredundant, redundant) =>
               ZIO.effect {
                 nonredundant.foreach(nonredundantRDFWriter.triple)
                 redundant.foreach(redundantRDFWriter.triple)
               }
           }
-          // _ <- watchFiber.join
           stop <- ZIO.effectTotal(System.currentTimeMillis())
           _ <- ZIO.effectTotal(scribe.info(s"Computed relations in ${(stop - start) / 1000.0}s"))
         } yield ()