code: @Override
      synchronized public void write(final byte data[], final int off, 
          final int len) throws IOException {
          
          // TODO: Ideally we'd make sure to fill up each message as much as
          // we can, but this will work for now!
          final byte[] encoded = CommonUtils.encode(this.key, data, off, len);
          os.write(encoded);
      }
docs: Write the data out, NOW.