<commit_before>package oncue.svc.funnel.agent

import oncue.svc.funnel.zeromq._
import scalaz.stream.async.signal
import scalaz.stream.async.mutable.Signal
import scalaz.stream.Process
import scalaz.concurrent.Task

class Proxy(I: Endpoint, O: Endpoint){
  private val alive: Signal[Boolean] = signal[Boolean]
  private val stream: Process[Task,Boolean] =
    Ø.link(O)(alive.continuous)(s =>
      Ø.link(I)(alive.continuous)(Ø.receive
        ).map(_.bytes).through(Ø.write(s)))

  def task: Task[Unit] =
    for {
      _ <- alive.set(false)
      _ <- stream.run
    } yield ()
}<commit_msg>correcting some agent code<commit_after>package oncue.svc.funnel.agent

import oncue.svc.funnel.zeromq._
import scalaz.stream.async.signal
import scalaz.stream.async.mutable.Signal
import scalaz.stream.Process
import scalaz.concurrent.Task

class Proxy(I: Endpoint, O: Endpoint){
  private val alive: Signal[Boolean] = signal[Boolean]
  private val stream: Process[Task,Boolean] =
    Ø.link(O)(alive)(s =>
      Ø.link(I)(alive)(Ø.receive
        ).map(_.bytes).through(Ø.write(s)))

  def task: Task[Unit] =
    for {
      _ <- alive.set(true)
      _ <- stream.run
    } yield ()
}
{'fraction_non_alphanumeric': 0.14067796610169492, 'fraction_numerical': 0.0, 'mean_word_length': 3.6865079365079363, 'pattern_counts': {'":': 0, '<': 7, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7036131', 'n_tokens_mistral': 421, 'n_tokens_neox': 405, 'n_words': 75}