example_decoder_encoder.java

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;

import se.lth.control.labcomm.DecoderChannel;
import se.lth.control.labcomm.EncoderChannel;

public class example_decoder_encoder 
  implements data.Handler, log_message.Handler 
{

  DecoderChannel decoder;
  EncoderChannel encoder;

  public example_decoder_encoder(InputStream in, OutputStream out) 
    throws Exception 
  {
    decoder = new DecoderChannel(in);
    log_message.register(decoder, this);
    data.register(decoder, this);

    encoder = new EncoderChannel(out);
    log_message.register(encoder);
    data.register(encoder);
 
    try {
      decoder.run();
    } catch (java.io.EOFException e) {
    }
  }

  public void handle_data(float v) throws java.io.IOException {
    System.out.println("Got data");
    data.encode(encoder, v);
  }

  public void handle_log_message(log_message v) throws java.io.IOException {
    System.out.println("Got log_message");
    log_message.encode(encoder, v);
  }


  public static void main(String[] arg) throws Exception {
    example_decoder_encoder example = new example_decoder_encoder(
      new FileInputStream(new File(arg[0])),
      new FileOutputStream(new File(arg[1])));


    
  }

}