<commit_before>package reactify

import scala.concurrent.Future

trait Channel[T] extends Observable[T] {
  /**
    * Convenience method to send a value to `set` similarly to an assignment operator.
    *
    * @param value the value to apply
    */
  def :=(value: => T): Unit = set(value)

  /**
    * Convenience method to send the result of a Future to this channel upon success.
    *
    * @param future the future to monitor
    * @return mapped `future` to conclude upon setting the value to this channel
    */
  def !(future: Future[T]): Future[Unit] = future.map { value =>
    set(value)
  }
<commit_msg>Minor fix.<commit_after>package reactify

import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global

trait Channel[T] extends Observable[T] {
  /**
    * Convenience method to send a value to `set` similarly to an assignment operator.
    *
    * @param value the value to apply
    */
  def :=(value: => T): Unit = set(value)

  /**
    * Convenience method to send the result of a Future to this channel upon success.
    *
    * @param future the future to monitor
    * @return mapped `future` to conclude upon setting the value to this channel
    */
  def !(future: Future[T]): Future[Unit] = future.map { value =>
    set(value)
  }

{'fraction_non_alphanumeric': 0.10334110334110334, 'fraction_numerical': 0.0, 'mean_word_length': 3.1414790996784565, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 7, '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': '656070', 'n_tokens_mistral': 375, 'n_tokens_neox': 375, 'n_words': 145}