Cover image for Asynchronous Easy pipeline in Android

Asynchronous Easy pipeline in Android

alialp profile image Ali Alp Updated on ・2 min read

Lets suppose the following logic in an Android Application

  • Call an API_A
  • Save the result in the local DB
  • Notify the user Interface
  • send statistic to another API_B
  • send back progress updates on each step to the caller

We know that we have to take care of all these operations in separate thread.

Find the Maven Repository here
Find the source code here


will take care of the above example as easy as the following code

new Pipeline(pipelineData)
        .Next(new Call_API_A(),25F)
        .Next(new Save_To_Local_DB(),50F)
        .Next(new Notify_The_UI(),75F)
        .Next(new Send_Statistics(),100F)


is the object which will travel through all the Workstations

public class PipelineData implements IPipelineData {
    //have your properties here


A step in a pipeline, in the above example Call_API_A() is a workstation

public class Call_API_A extends WorkStation {

    protected void invoke(IPipelineData data) throws Exception {

        PipelineData pipelineData = (PipelineData) data;

        //do the work


therefore for each step or workstation you will create a class which must inherit from the WorkStation class and the PipelineData object will be available to it.

Request Code

is an integer which you need to provide the pipeline with, to be able to handle the pipeline's tasks asynchronous, therefore when the pipeline finishes its work ,means that the last workstation has finished its work then the pipeline will call its callback with its request code , therefore you can have multiple pipelines in one class.

You can use it synchronously like this

public void SyncTest() throws Exception {

    pipelineData = new PipelineData();

    PipelineData result = (PipelineData) new Pipeline(pipelineData)
            .next(new WorkStation1())
            .next(new WorkStation2())
            .next(new WorkStation3())
            .next(new WorkStation4())

    Assert.assertEquals(result.getResult().size(), 4);

or Asynchronously like this

public void AsyncTest() throws InterruptedException {

    pipelineData = new PipelineData();

    new Pipeline(pipelineData)
            .next(new WorkStation1(), /*progress=*/ 20F, /*requestCode=*/ 11)
            .next(new WorkStation2())
            .next(new WorkStation3(), /*progress=*/ 12F)
            .next(new WorkStation4(), /*progress=*/ 100F)
            .runAsync(this, ReqCode);


    Assert.assertEquals(((PipelineData) (pipelineResult.getPipelineData())).getResult().size(), 4);
    Assert.assertEquals(pipelineResult.getRequestCode(), ReqCode);
    Assert.assertEquals(pipelineResult.isSuccess(), true);

public void OnResult(PipelineResult result) {
    if (result.isSuccess()) {
        Log.d("REQ-" + ReqCode, String.valueOf(result.getPipelineData()));
    } else {

    pipelineResult = result;

public void OnProgress(Integer sourcePipelineHashCode, Integer workStationRequestCode, Float progress) {
    Log.d("REQ-" + sourcePipelineHashCode, " WorkStationReqCode: " + workStationRequestCode + " progress: " + progress);

you can find here the rest of the test cases

Happy coding :)

Find the Maven Repository here
Find the source code here

Posted on by:

alialp profile

Ali Alp


“Take it easy” is nonsense , take it as hard as you can and don’t let it go :)


markdown guide