// Saves resized image to the output dir
func (s *ImageResizer) SaveResizedImageTask(j job.Job) (job.Init, job.Run, job.Finalize) {
  // Do some initialization here
  init := func(t job.Task) {
    if _, err := os.Stat(s.inputDir); os.IsNotExist(err) {
      t.Assert(err)
    }
    if _, err := os.Stat(s.outputDir); os.IsNotExist(err) {
      err := os.Mkdir(s.outputDir, 755)
      t.Assert(err)
    }
  }
  run := func(task job.Task) {
    stream := j.GetValue().(netmanager.Stream)
    select {
    case finishedTask := <- j.TaskDoneNotify(): // Wait for the scanner task to be done
      if finishedTask.GetIndex() == s.scanneridx {
        s.scandone = true
      }
      task.Tick()
    case frame := <-stream.RecvDataFrame(): // Process response from the backend server
      task.AssertNotNil(frame)
      res := &imgresize.Response{}
      err := frame.Decode(res)
      task.Assert(err)
      baseName := fmt.Sprintf("%s-%dx%d%s",
        res.OriginalName, res.ResizedWidth, res.ResizedHeight, res.Typ.ToFileExt())
      filename := s.outputDir + string(os.PathSeparator) + baseName
      if ! s.dryRun {
        ioutil.WriteFile(filename, res.ImgData, 0775)
      }
      j.Log(1) <- fmt.Sprintf("file %s has been saved", filename)
      stream.RecvDataFrameSync() // Tell netmanager.ReadTask that we are done processing the frame
      s.recvx++
      task.Tick()
    default:
      switch {
      case s.scandone && s.recvx == s.sentx: // Check if all found images were processed
        task.FinishJob()
      default:
        task.Idle() // Do nothing
      }
    }
  }
  return init, run, nil
}