experquisite

use std::io::{stdout, Stdout, Write};
use std::sync::mpsc;

struct SpaceLogHandler<X> {
    read_channel: mpsc::Receiver<X>,
    write_channel: mpsc::Sender<X>,
    handler: Box<std::io::Write>,
}

impl<X> SpaceLogHandler<X> {

experquisite

sdf

experquisite

package sharetest

import rx.lang.scala.Observable
import rx.lang.scala.subjects.PublishSubject

class SourceSim {
  private val subject = PublishSubject[Double]()

  private val random = scala.util.Random