Amazon S3をRXに送信するandroid observable

Question

RX And​​roidを使用するようにこの非同期呼び出しを変換する方法と、 を他の呼び出しにチェーンする方法はありますか？ 現在、EventBusを使用して送信が成功したか失敗したかを通知しますが、主に連鎖目的でRXを使用したいと考えています。

public void SendToAmazon(Intent i) { 
    try { 
     // take params from intent 
     // ....................... 

     // Create an S3 client 
     s3Client = new AmazonS3Client(new BasicAWSCredentials(MY_ACCESS_KEY_ID, MY_SECRET_KEY)); 
     // Set the region of your S3 bucket 
     s3Client.setRegion(com.amazonaws.regions.Region.getRegion(Regions.EU_CENTRAL_1)); 

     String newFilename = fileName+"/img.jpg"; 
     PutObjectRequest putObjectRequest = new PutObjectRequest(
       AmazonS3FetchParams.MY_BUCKET_NAME, newFilename, new java.io.File(fileURI)) 
       .withCannedAcl(CannedAccessControlList.PublicRead) 
       .withStorageClass(StorageClass.Standard); 
     try { 
      putObjectRequest.setGeneralProgressListener(new S3ProgressListener() { 
       @Override 
       public void onPersistableTransfer(PersistableTransfer persistableTransfer) { 

       } 

       @Override 
       public void progressChanged(com.amazonaws.event.ProgressEvent progressEvent) { 
        if (progressEvent.getEventCode() == ProgressEvent.COMPLETED_EVENT_CODE) { 
         Log.d("Info", "TRANSFER finished: " + progressEvent.getBytesTransferred() + " bytes"); 
         SentToS3Event sentEvent = new SentToS3Event(fileName, fileURI, position, 
           0, from, nrRetry, messageDbId, getAmazonImageUrl(fileName)); 
         EventBus.getDefault().post(sentEvent); 
        } else if (progressEvent.getEventCode() == ProgressEvent.FAILED_EVENT_CODE) { 
         SentToS3Event sentEvent = new SentToS3Event(fileName, fileURI, position, 
           -1, from, nrRetry, messageDbId, getAmazonImageUrl(fileName)); 
         EventBus.getDefault().post(sentEvent); 
        } 
       } 
      }); 

      PutObjectResult objectResult = s3Client.putObject(putObjectRequest); 
      error = 0; 
     } catch (AmazonClientException aex) { 
      Log.e("Info", "AMAZON EXCEPTION ! " + aex.getMessage()); 
     } 
    } catch (Exception e) { 
     error = -1; 
    } 
} 

`

Answer 1

コードのこの作品を見てみましょう。私は別の状況でそれを動作させることができました。

final PutObjectRequest putObjectRequest = new PutObjectRequest("a", "b", "c"); 
    Observable.create(new Observable.OnSubscribe<SomeAmazonModel>() { 
     @Override 
     public void call(final Subscriber<? super SomeAmazonModel> subscriber) { 
      putObjectRequest.setGeneralProgressListener(new S3ProgressListener() { 
       @Override 
       public void onPersistableTransfer(PersistableTransfer persistableTransfer) { 

       } 

       @Override 
       public void progressChanged(com.amazonaws.event.ProgressEvent progressEvent) { 
        if (progressEvent.getEventCode() == ProgressEvent.COMPLETED_EVENT_CODE) { 
         subscriber.onNext(new SomeAmazonModel(ProgressEvent.COMPLETED_EVENT_CODE)); 
         subscriber.onCompleted(); 
        } else if (progressEvent.getEventCode() == ProgressEvent.FAILED_EVENT_CODE) { 
         subscriber.onNext(new SomeAmazonModel(ProgressEvent.COMPLETED_EVENT_CODE)); 
        } 
       } 
      }); 
     } 
    }).subscribe(new Action1<SomeAmazonModel>() { 
     @Override 
     public void call(SomeAmazonModel someAmazonModel) { 
      // Subscribe to above Observable and handle result 
      someAmazonModel.getEventCode(); 
     } 
    });