palevomr / janet-command Goto Github PK

Janet janet = new Janet.Builder().addService(new CommandActionService()).build();

@CommandAction
class CopyBitmapToFileCommand extends Command<File> {

    private final Context context;
    private final String bitmapPath;
    //
    private File newFile;

    public CopyBitmapToFileCommand(Context context, String bitmapPath) {
        this.context = context;
        this.bitmapPath = bitmapPath;
    }

    @Override protected void run(CommandCallback<File> callback) throws Throwable {
        // Pre-check arguments
        if (TextUtils.isEmpty(bitmapPath)) {
            callback.onFail(new IllegalArgumentException("Source path is empty"));
            return;
        }
        // Do the job
        String tmpBitmapPrefix = "bitmap_" + System.currentTimeMillis();
        try {
            newFile = BitmapUtil.decodeToTmp(context, bitmapPath, tmpBitmapPrefix);
            callback.onSuccess(newFile);
        } catch (IOException e) {
            callback.onFail(e);
        }
    }

    @Override protected void cancel() {
        // cleanup resources
        if (newFile != null && newFile.exists()) newFile.delete();
    }
}

ActionPipe<CopyBitmapToFileCommand> actionPipe = janet.createPipe(CopyBitmapToFileCommand.class);
actionPipe
  .createObservable(new CopyBitmapToFileCommand(context, sourceBitmapPath))
  .subscribeOn(Schedulers.io())
  .subscribe(new ActionStateSubscriber<CopyBitmapToFileCommand>()
          .onSuccess(action -> System.out.println("Got new file " + action.getResult()))
          .onFail((action, throwable) -> System.err.println("Bad things happened " + throwable))
  );